} catch (IOException ex) { }
        return connection.getInputStream();
    }

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

        try ( SmbFile f = createTestFile() ) {
            try {
                try ( OutputStream os = f.getOutputStream() ) {
                    writeRandom(bufSize, length, os);
                }

                assertEquals("File size matches", length, f.length());

                  SmbFile t = new SmbFile(d1, makeRandomName()) ) {
                try {
                    try ( OutputStream os = f.getOutputStream() ) {
                        ReadWriteTest.writeRandom(bufSize, length, os);
                    }

                    try ( OutputStream os = t.getOutputStream() ) {
                        ReadWriteTest.writeRandom(bufSize, 2 * length, os);
                    }

                    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()) {

        return this.connection.getInputStream();
    }


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


    @Override

                    logger.fine(() -> ">>> " + body);
                    connection.setDoOutput(true);
                    try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream(), encoding))) {
                        writer.write(body);
                        writer.flush();
                    }
                } else if (bodyStream != null) {

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

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

            SessionServicePacket ssp = new SessionRequestPacket( calledName,
                    NbtAddress.getLocalName() );

        try (XContentBuilder builder = JsonXContent.contentBuilder().map(firstLineMap)) {
            builder.flush();
            return builder.getOutputStream();
        }
    }

    public static ReadingConverter createDefaultReadingConverter(final Client client, final SuggestSettings settings) {
        final ReadingConverterChain chain = new ReadingConverterChain();

            try (final BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(tempFile)));
                    final BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(con.getOutputStream(), Constants.CHARSET_UTF_8))) {
                String line;
                while ((line = br.readLine()) != null) {
                    if (StringUtil.isNotBlank(line)) {

            int soTimeout = ctx.getConfig().getSoTimeout();
            f.createNewFile();
            try {
                try ( OutputStream os = f.getOutputStream() ) {
                    os.write(new byte[] {
                        1, 2, 3, 4, 5, 6, 7, 8
                    });
                }

                try ( InputStream is = f.getInputStream() ) {