@@ -16,7 +16,7 @@ import {
1616import { Headers } from "effect/unstable/http"
1717import { Rpc , RpcSchema } from "effect/unstable/rpc"
1818
19- const MemoryLive = MessageStorage . layerMemory . pipe (
19+ const MemoryLayer = MessageStorage . layerMemory . pipe (
2020 Layer . provideMerge ( Snowflake . layerGenerator ) ,
2121 Layer . provide ( ShardingConfig . layerDefaults )
2222)
@@ -57,7 +57,7 @@ describe("MessageStorage", () => {
5757 expect ( result . _tag ) . toEqual ( "Success" )
5858 const messages = yield * storage . unprocessedMessages ( [ request . envelope . address . shardId ] )
5959 expect ( messages ) . toHaveLength ( 1 )
60- } ) . pipe ( Effect . provide ( MemoryLive ) ) )
60+ } ) . pipe ( Effect . provide ( MemoryLayer ) ) )
6161
6262 it . effect ( "detects duplicates" , ( ) =>
6363 Effect . gen ( function * ( ) {
@@ -75,7 +75,7 @@ describe("MessageStorage", () => {
7575 } )
7676 )
7777 expect ( result . _tag ) . toEqual ( "Duplicate" )
78- } ) . pipe ( Effect . provide ( MemoryLive ) ) )
78+ } ) . pipe ( Effect . provide ( MemoryLayer ) ) )
7979
8080 it . effect ( "unprocessedMessages excludes complete requests" , ( ) =>
8181 Effect . gen ( function * ( ) {
@@ -85,7 +85,7 @@ describe("MessageStorage", () => {
8585 yield * storage . saveReply ( yield * makeReply ( request ) )
8686 const messages = yield * storage . unprocessedMessages ( [ request . envelope . address . shardId ] )
8787 expect ( messages ) . toHaveLength ( 0 )
88- } ) . pipe ( Effect . provide ( MemoryLive ) ) )
88+ } ) . pipe ( Effect . provide ( MemoryLayer ) ) )
8989
9090 it . effect ( "repliesFor" , ( ) =>
9191 Effect . gen ( function * ( ) {
@@ -98,7 +98,7 @@ describe("MessageStorage", () => {
9898 replies = yield * storage . repliesFor ( [ request ] )
9999 expect ( replies ) . toHaveLength ( 1 )
100100 expect ( replies [ 0 ] . requestId ) . toEqual ( request . envelope . requestId )
101- } ) . pipe ( Effect . provide ( MemoryLive ) ) )
101+ } ) . pipe ( Effect . provide ( MemoryLayer ) ) )
102102
103103 it . effect ( "registerReplyHandler" , ( ) =>
104104 Effect . gen ( function * ( ) {
@@ -116,7 +116,7 @@ describe("MessageStorage", () => {
116116 yield * storage . saveReply ( yield * makeReply ( request ) )
117117 yield * latch . await
118118 yield * Fiber . await ( fiber )
119- } ) . pipe ( Effect . provide ( MemoryLive ) ) )
119+ } ) . pipe ( Effect . provide ( MemoryLayer ) ) )
120120 } )
121121} )
122122
0 commit comments