30<\/a><\/strong><\/pre><\/td>\n final<\/span> <\/span>class<\/span> <\/span>MonoJust<\/span><<\/span>T<\/span>><\/span>
<\/span>extends<\/span> <\/span>Mono<\/span><<\/span>T<\/span>><\/span>
<\/span>implements<\/span> <\/span>Fuseable<\/span>.<\/span>ScalarCallable<\/span><<\/span>T<\/span>><\/span>,<\/span> <\/span>Fuseable<\/span> <\/span>{<\/span>
<\/span>final<\/span> <\/span>T<\/span> <\/span>value<\/span>;<\/span>
<\/span>MonoJust<\/span>(<\/span>T<\/span> <\/span>value<\/span>)<\/span> <\/span>{<\/span>
<\/span>this<\/span>.<\/span>value<\/span> <\/span>=<\/span> <\/span>Objects<\/span>.<\/span>requireNonNull<\/span>(<\/span>value<\/span>,<\/span> <\/span>"<\/span>value<\/span>"<\/span><\/span>)<\/span>;<\/span>
<\/span>}<\/span>
<\/span>@Override<\/span>
<\/span>public<\/span> <\/span>T<\/span> <\/span>call<\/span>(<\/span>)<\/span> <\/span>{<\/span>
<\/span>return<\/span> <\/span>value<\/span>;<\/span>
<\/span>}<\/span>
<\/span>@Override<\/span>
<\/span>public<\/span> <\/span>T<\/span> <\/span>block<\/span>(<\/span>Duration<\/span> <\/span>m<\/span>)<\/span> <\/span>{<\/span>
<\/span>return<\/span> <\/span>value<\/span>;<\/span>
<\/span>}<\/span>
<\/span>@Override<\/span>
<\/span>public<\/span> <\/span>T<\/span> <\/span>block<\/span>(<\/span>)<\/span> <\/span>{<\/span>
<\/span>return<\/span> <\/span>value<\/span>;<\/span>
<\/span>}<\/span>
<\/span>@Override<\/span>
<\/span>public<\/span> <\/span>void<\/span> <\/span>subscribe<\/span>(<\/span>Subscriber<\/span><<\/span>?<\/span> <\/span>super<\/span> <\/span>T<\/span>><\/span> <\/span>s<\/span>)<\/span> <\/span>{<\/span>
<\/span>s<\/span>.<\/span>onSubscribe<\/span>(<\/span>Operators<\/span>.<\/span>scalarSubscription<\/span>(<\/span>s<\/span>,<\/span> <\/span>value<\/span>)<\/span>)<\/span>;<\/span>
<\/span>}<\/span>
<\/span>}<\/span>
<\/span><\/pre><\/td>\n<\/tr><\/table>\n\n");
|