.subscribe(new Subscriber<LifecycleState>() {
@Override
public void onCompleted() {
pinnedEndpoints.add(endpoint);
endpoint.send(request);
endpoint.send(SignalFlush.INSTANCE);
}
@Override
public void onError(Throwable e) {
request.observable().onError(e);