public static Observable<Void> create(final ServletOutputStream out) {
    """
	Observes {@link ServletOutputStream}.
	
	<p>
	This method uses Servlet 3.1 non-blocking API callback mechanisms. When the
	container notifies that HTTP response can be written, the subscribed
	{@code Observer}'s {@link Observer#onNext onNext} method is invoked.
	
	<p>
	Before calling this method, a web application must put the corresponding HTTP
	request into asynchronous mode.
	
	@param out servlet output stream
	@return Observable of HTTP response write ready events
    """
        return Observable.unsafeCreate(subscriber -> {
            final ServletWriteListener listener = new ServletWriteListener(subscriber, out);
            out.setWriteListener(listener);
        });
    }
public static Observable<Void> create(final ServletOutputStream out) {
        return Observable.unsafeCreate(subscriber -> {
            final ServletWriteListener listener = new ServletWriteListener(subscriber, out);
            out.setWriteListener(listener);
        });
    }
public static Observable < Void > create ( final ServletOutputStream out ) { return Observable . unsafeCreate ( subscriber -> { final ServletWriteListener listener = new ServletWriteListener ( subscriber , out ) ; out . setWriteListener ( listener ) ; } ) ; }
Observes {@link ServletOutputStream}.

<p>
This method uses Servlet 3.1 non-blocking API callback mechanisms. When the
container notifies that HTTP response can be written, the subscribed
{@code Observer}'s {@link Observer#onNext onNext} method is invoked.

<p>
Before calling this method, a web application must put the corresponding HTTP
request into asynchronous mode.

@param out servlet output stream
@return Observable of HTTP response write ready events
Observes { @link ServletOutputStream } .