…ditions

Unsubscribing due to a timeout does not guarantee synchronization with upstream.

Therefore, we implemented an attempt attemptTerminate() method.

Lint error correction

1. remove @throws from docs
2. add @UnstableApi with timeout method
3. public -> final
4. add @nullable to timeoutSubscriber
5. cancel() override (add cancelSchedule())
6. lastontime nano -> lasteventtime nano
7. createTimeoutSchedule -> scheduleTimeout
8. call onError after canceling

2. onNext -> Delete isCancelled() from condition
case UNTIL_FIRST:
Change timeoutfuture.cancel(false)  to cancelSchedule()

2. add docs to StreamTimeoutMode parameter
3. use test code executor.get()

…and set the timeout schedule

2. change TimeoutSubscriber class to TimeoutStreamMessage's inner class

…meoutMode`

2. Added leak prevention code when completed in onNext() - PooledObjects.close(t)

2. Add a StreamTimeoutException
3. Overriding WebSocket's timeout method
4. Remove cancelSchedule() from abort()
5. Set timeoutFuture to null to avoid calling .isCancelled() which may access a volatile field.
6. Modify boolean cancels to volatile boolean cancels