open method

@override Future open()

Begins listening for HTTP requests on port.

Implementation

@override
Future open() async {
  server = await HttpServer.bind(InternetAddress.loopbackIPv4, port);
  server!.map((req) => Request(req)).listen((req) async {
    add(req);

    await req.body.decode();

    final response = await _dequeue(req);
    if (response != null) {
      await req.respond(response);
    }
  });
}