Searched refs:pipeSinkTimeoutNanos (Results 1 – 1 of 1) sorted by relevance
221 val pipeSinkTimeoutNanos = smallerTimeoutNanos in honorsPipeSinkTimeoutOnWritingWhenUnderlyingSinkTimeoutIsZero() constant226 pipe.sink.timeout().timeout(pipeSinkTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnWritingWhenUnderlyingSinkTimeoutIsZero()230 assertDuration(pipeSinkTimeoutNanos) { in honorsPipeSinkTimeoutOnWritingWhenUnderlyingSinkTimeoutIsZero()253 val pipeSinkTimeoutNanos = smallerTimeoutNanos in honorsPipeSinkTimeoutOnFlushingWhenUnderlyingSinkTimeoutIsZero() constant258 pipe.sink.timeout().timeout(pipeSinkTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnFlushingWhenUnderlyingSinkTimeoutIsZero()262 assertDuration(pipeSinkTimeoutNanos) { in honorsPipeSinkTimeoutOnFlushingWhenUnderlyingSinkTimeoutIsZero()285 val pipeSinkTimeoutNanos = smallerTimeoutNanos in honorsPipeSinkTimeoutOnClosingWhenUnderlyingSinkTimeoutIsZero() constant290 pipe.sink.timeout().timeout(pipeSinkTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnClosingWhenUnderlyingSinkTimeoutIsZero()294 assertDuration(pipeSinkTimeoutNanos) { in honorsPipeSinkTimeoutOnClosingWhenUnderlyingSinkTimeoutIsZero()