createCoordinationStream method

  1. @override
Future<WsCoordinationStream> createCoordinationStream(
  1. CoordinationStreamConfig config,
  2. CoordinationSession session
)
override

Creates a coordination stream with the given configuration and session context.

Implementation

@override
Future<WsCoordinationStream> createCoordinationStream(
  CoordinationStreamConfig config,
  CoordinationSession session,
) async => WsCoordinationStream(
  config: config,
  connection: connection,
  sessionName: session.config.name,
  streamNode: session.thisNode,
);