plugAndStartWithIO function

Future<void> plugAndStartWithIO(
  1. HttpRequest request,
  2. EventRegister eventRegister, {
  3. ZapIdStrategy idStrategy = const DefaultIDStrategy(),
})

Implementation

Future<void> plugAndStartWithIO(
  HttpRequest request,
  EventRegister eventRegister,
  {
    ZapIdStrategy idStrategy = const DefaultIDStrategy()
  }
) async{
    final websocket = await WebSocketTransformer.upgrade(request);
    final adapter = IOadapter(websocket);
    final eventCaller = EventCaller(eventRegister.eventBook);
    final id = idStrategy.eval();
    final wsConn = WebSocketConnection(id, adapter);
    final proccesor = EventProcessor(eventCaller, wsConn);
    proccesor.notifyConnected();
    websocket.listen(
      proccesor.interceptRawData,
      onDone: () => proccesor.notifyDisconnected(),
    );
}