thosakwe / http2_client Goto Github PK

Bad state: The http/2 connection is no longer active and can therefore not be used to make new streams.
#0      ClientConnection.makeRequest (package:http2/src/connection.dart:465:7)
#1      Http2Client._send.<anonymous closure> (package:http2_client/http2_client.dart:126:32)
<asynchronous suspension>
...

    var headers = [
      Header.ascii(':authority', request.url.authority),
      Header.ascii(':method', request.method),
      Header.ascii(':path', request.url.path),
      Header.ascii(':scheme', request.url.scheme),
    ];

  final String _authString;

  AuthClient(
    username,
    password, {
    BaseClient http1Client,
    bool autoUncompress = true,
    bool maintainOpenConnections = true,
    int maxOpenConnections = -1,
    Function onBadCertificate,
    SecurityContext context,
    Duration timeout,
  })  : _authString = _getAuthString(username, password),
        super(
          http1Client: http1Client,
          autoUncompress: autoUncompress,
          maintainOpenConnections: maintainOpenConnections,
          maxOpenConnections: maxOpenConnections,
          onBadCertificate: onBadCertificate,
          context: context,
          timeout: const Duration(seconds: 60),
        );

  static String _getAuthString(username, password) {
    final token = base64Encode(utf8.encode('$username:$password'));

    return "Basic ${token.trim()}";
  }

  BaseRequest _setHeaders(BaseRequest request) => request
    ..headers[HttpHeaders.authorizationHeader] = _authString
    ..headers[HttpHeaders.contentLengthHeader] =
        request.contentLength.toString();

  @override
  Future<StreamedResponse> send(BaseRequest request) {
    return super.send(_setHeaders(request));
  }
}

AuthClient c = AuthClient("username", "password",
    maxOpenConnections: Platform.numberOfProcessors);
Response response = await c.get(url);
c.close();

c = AuthClient("username", "password");
return Future.wait([
    c.get(url1),
    c.get(url2),
    c.get(url3),
]);