Function makeRunnerLayer

packages/platform-node/test/NodeClusterSocket.test.ts:51–64

(port: number)

)

const makeRunnerLayer = (port: number) =>
  TestEntityLayer.pipe(
    Layer.provideMerge(SocketRunner.layer),
    Layer.provide(RunnerHealth.layerNoop),
    Layer.provide(NodeClusterSocket.layerSocketServer),
    Layer.provide(NodeClusterSocket.layerClientProtocol),
    Layer.provide(ShardingConfig.layer({
      runnerAddress: Option.some(RunnerAddress.make("localhost", port)),
      entityTerminationTimeout: 0,
      entityMessagePollInterval: 5000,
      sendRetryInterval: 100
    })),
    Layer.provide(RpcSerialization.layerMsgPack)
  )

const makeClientLayer = (port: number) =>
  SocketRunner.layerClientOnly.pipe(