return connection.getInputStream();
    }

    @Override
    public OutputStream getOutputStream() throws IOException {
        try {
            connect();
        } catch (final IOException ex) {}
        final OutputStream output = connection.getOutputStream();
        cachedOutput = new ByteArrayOutputStream();
        return new CacheStream(output, cachedOutput);
    }

    public InputStream getInputStream() throws IOException {
        return new SocketInputStream(super.getInputStream());
    }

    @Override
    public OutputStream getOutputStream() throws IOException {
        return new SocketOutputStream(super.getOutputStream());
    }

    @Override
    public int getPort() {
        return super.getPort();
    }

    @Override
    public InetAddress getLocalAddress() {

                    CopyUtil.copy(in, out);
                } catch (final IOException e) {
                    throw new WebApiException(HttpServletResponse.SC_BAD_REQUEST, e);
                }
            }
        }).execute()) {

            try (ServletOutputStream out = response.getOutputStream(); InputStream in = curlResponse.getContentAsStream()) {

        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);
        byte[] testData = "test data".getBytes();
        os.write(testData);
        os.flush();

        handshake();
        return this.connection.getInputStream();
    }

    @SuppressWarnings("resource")
    @Override
    public OutputStream getOutputStream() throws IOException {
        connect();
        final OutputStream output = this.connection.getOutputStream();
        this.cachedOutput = new ByteArrayOutputStream();
        return new CacheStream(output, this.cachedOutput);
    }

    @Override

    private val remoteAddress: InetAddress = localAddress,
    private val remotePort: Int = 1234,
  ) : Socket() {
    override fun getInputStream() = Buffer().inputStream()

    override fun getOutputStream() = Buffer().outputStream()

    override fun getInetAddress() = remoteAddress

    override fun getLocalAddress() = localAddress

    override fun getLocalPort() = localPort

                    0);
        }

        @Test
        void testGetOutputStream() throws IOException {
            // Act
            var outputStream = smbFile.getOutputStream();

            // Assert
            assertNotNull(outputStream);
            verify(smbFile).openUnshared(SmbConstants.O_CREAT | SmbConstants.O_WRONLY | SmbConstants.O_TRUNC, // 82

            @Override
            public String getContentType() {
                return null;
            }

            @Override
            public jakarta.servlet.ServletOutputStream getOutputStream() {
                return null;
            }

            @Override
            public java.io.PrintWriter getWriter() {
                return null;
            }

            @Override

        }

        @Override
        public String getContentType() {
            return null;
        }

        @Override
        public jakarta.servlet.ServletOutputStream getOutputStream() {
            return null;
        }

        @Override
        public java.io.PrintWriter getWriter() {
            return null;
        }

        @Override

            }
            socket.connect(new InetSocketAddress(address.getHostAddress(), 139), CONN_TIMEOUT);
            socket.setSoTimeout(SO_TIMEOUT);

            out = socket.getOutputStream();
            in = socket.getInputStream();

            final SessionServicePacket ssp = new SessionRequestPacket(calledName, NbtAddress.getLocalName());
            out.write(sbuf, 0, ssp.writeWireFormat(sbuf, 0));