Skip to content
This repository was archived by the owner on Mar 2, 2022. It is now read-only.

Commit e64bb6d

Browse files
committed
Removed Mono.awaitOnSubscribe
Signed-off-by: Winarto Zhao <[email protected]>
1 parent 3ed2cf3 commit e64bb6d

File tree

1 file changed

+0
-16
lines changed
  • src/main/scala/reactor/core/scala/publisher

1 file changed

+0
-16
lines changed

src/main/scala/reactor/core/scala/publisher/Mono.scala

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -98,22 +98,6 @@ class Mono[T] private(private val jMono: JMono[T])
9898
}))
9999
}
100100

101-
/**
102-
* Intercepts the onSubscribe call and makes sure calls to Subscription methods
103-
* only happen after the child Subscriber has returned from its onSubscribe method.
104-
*
105-
* <p>This helps with child Subscribers that don't expect a recursive call from
106-
* onSubscribe into their onNext because, for example, they request immediately from
107-
* their onSubscribe but don't finish their preparation before that and onNext
108-
* runs into a half-prepared state. This can happen with non Reactor based
109-
* Subscribers.
110-
*
111-
* @return non reentrant onSubscribe [[Mono]]
112-
*/
113-
final def awaitOnSubscribe(): Mono[T] = new Mono[T](
114-
jMono.awaitOnSubscribe()
115-
)
116-
117101
/**
118102
* Block until a next signal is received, will return null if onComplete, T if onNext, throw a
119103
* `Exceptions.DownstreamException` if checked error or origin RuntimeException if unchecked.

0 commit comments

Comments
 (0)