code: private void offer(ResultStream<? super T> resultStream)
    {
      long expires = 600 * 1000L;
  
      try (OutboxAmp outbox = OutboxAmp.currentOrCreate(_serviceRef.services())) {
        HeadersAmp headers = HeadersNull.NULL;
      
        ResultStream<U> stream = build(resultStream);
      
        StreamCallMessage<U> msg;
        msg = new StreamCallMessage<U>(outbox, outbox.inbox(), headers,
                                       _serviceRef, _method, 
                                       stream,
                                       expires, _args);
        
        long timeout = 10000;
  
        msg.offer(timeout);
      }
    }
docs: /*
  private <R> R doFuture(Consumer<Result<R>> task)
  {
  return _serviceRef.getManager().run(60, TimeUnit.SECONDS, task);
  }