* @return the output stream, or null if not set
     */
    @Nullable
    OutputStream stdOut();

    /**
     * Returns the error stream to be used for the Maven execution.
     * If not set, {@link System#err} will be used by default.
     *
     * @return the error stream, or null if not set
     */
    @Nullable
    OutputStream stdErr();

    /**

            builder.field("test", "value");
            builder.endObject();
            return builder;
        };

        OutputStream outputStream = SearchEngineUtil.getXContentBuilderOutputStream(callback, XContentType.JSON);
        assertNotNull(outputStream);
        assertTrue(outputStream instanceof ByteArrayOutputStream);
    }

    public void test_getXContentBuilderOutputStream_ioException() {

        connection.setUseCaches(useCaches);
    }

    private static class CacheStream extends OutputStream {

        private final OutputStream stream;

        private final OutputStream collector;

        public CacheStream(final OutputStream stream, final OutputStream collector) {
            this.stream = stream;
            this.collector = collector;
        }

        @Override

        assertDoesNotThrow(() -> outputStream.write(data, 0, -1)); // negative length, returns early
        assertDoesNotThrow(() -> outputStream.write(data, 0, 0)); // zero length, returns early

        // These should pass through to the underlying implementation
        assertDoesNotThrow(() -> outputStream.write(data, 0, 10)); // valid - will consume first mock (10)

            // When
            OutputStream os1 = mockResource.openOutputStream();
            OutputStream os2 = mockResource.openOutputStream(true);
            OutputStream os3 = mockResource.openOutputStream(false, 1);
            OutputStream os4 = mockResource.openOutputStream(true, 1, 2, 3);

            // Then

     * Wraps the output stream with a {@link BufferedOutputStream} if necessary.
     *
     * @param os the output stream
     * @return the wrapped output stream
     */
    protected static OutputStream wrap(final OutputStream os) {
        if (os instanceof BufferedOutputStream) {
            return os;
        }
        if (os instanceof ByteArrayOutputStream) {
            return os;
        }

 */

package jcifs.smb1.smb1;

import java.io.IOException;
import java.io.OutputStream;
import java.net.MalformedURLException;
import java.net.UnknownHostException;

import jcifs.smb1.util.LogStream;

/**
 * This <code>OutputStream</code> can write bytes to a file on an SMB file server.
 */

public class SmbFileOutputStream extends OutputStream {

    private final SmbFile file;
    private final boolean append, useNTSmbs;

        this.connection.setConnectTimeout(connectTimeout);
    }

    private static class CacheStream extends OutputStream {

        private final OutputStream stream;

        private final OutputStream collector;

        public CacheStream(final OutputStream stream, final OutputStream collector) {
            this.stream = stream;
            this.collector = collector;
        }

        @Override

import jcifs.internal.smb2.io.Smb2WriteRequest;
import jcifs.internal.smb2.io.Smb2WriteResponse;

/**
 * This <code>OutputStream</code> can write bytes to a file on an SMB file server.
 */

public class SmbFileOutputStream extends OutputStream {

    private static final Logger log = LoggerFactory.getLogger(SmbFileOutputStream.class);

    private final SmbFile file;
    private final boolean append;

        // Mock initial connection's output stream (needed for CacheStream)
        OutputStream initialOutputStream = mock(OutputStream.class);
        when(mockConnection.getOutputStream()).thenReturn(initialOutputStream);

        // Act
        // Get output stream and write data to it
        OutputStream os = ntlmConnection.getOutputStream();
        assertNotNull(os);