export const BinanceWsUnitSingleLayer = Layer.effect(
  BinanceWsUnitTag,
  Effect.gen(function* () {
    // ....................................................................
    return {
      createStream(
        stream: string,
      ): Stream.Stream<
        unknown,
        | BinanceWsConnectionError
        | BinanceWsResponseError
        | BinanceWsConnectionCloseError
      > {
        return Stream.suspend(() => {
          debug(`📤Requesting stream "${stream}"`);
          let stream$ = streams.get(stream);
          if (stream$) {
            return stream$;
          }
          stream$ = connection.pipe(
            Stream.flatMap(
              (ws) =>
                Effect.request(
                  BinanceWsSubscribeRequest({ stream, ws }),
                  RequestResolver.contextFromEffect(subscribe),
                ).pipe(
                  Stream.unwrap,
                  Stream.ensuring(
                    Effect.gen(function* () {
                      debug(`🔻 Unsubscribing ${stream}`);
                      streams.delete(stream);
                      yield* Effect.request(
                        BinanceWsUnsubscribeRequest({ stream, ws }),
                        RequestResolver.contextFromEffect(unsubscribe),
                      );
                    }),
                  ),
                ),
              { switch: true, concurrency: 1 },
            ),
          );
          streams.set(stream, stream$);
          return stream$;
        });
      },
    } satisfies BinanceWsUnit;
  }),
)