return getSeqnosForChannel(channel);
}
});
}
private Observable<ByteBuf> getSeqnosForChannel(final DcpChannel channel) {
<BUG>if (channel.state() != LifecycleState.CONNECTED) {
LOGGER.debug("Rescheduling get Seqnos for channel {}, not connected (yet).", channel);
return Observable
.timer(100, TimeUnit.MILLISECONDS)
.flatMap(new Func1<Long, Observable<ByteBuf>>() {
@Override
public Observable<ByteBuf> call(Long aLong) {
return getSeqnosForChannel(channel);</BUG>
}

return getSeqnosForChannel(channel);
}
});
}
private Observable<ByteBuf> getSeqnosForChannel(final DcpChannel channel) {
return Observable
.just(channel)
.flatMap(new Func1<DcpChannel, Observable<ByteBuf>>() {
