search

scalecube / scalecube-gateway

ScaleCube API Gateway is the single entry point for service consumers. handles incoming requests and proxy/route to the appropriate microservice instance.
Apache License 2.0
18 stars 7 forks source link

Add test on complete signal for WebSocket #103

Open segabriel opened 4 years ago

segabriel commented 4 years ago

WebSocket API: https://github.com/scalecube/scalecube-services/wiki/Web-Socket-API

Also it should work with local services which respond in another thread, example:

  @Override
  public Mono<String> one(String one) {
    return Mono.just(one);
  }

==>

  @Override
  public Mono<String> one(String one) {
    return Mono.delay(Duration.ofNanos(1), Schedulers.elastic()).thenReturn(one);
  }