}

        public void close() throws IOException {
            stream.close();
            collector.close();
        }

        public void flush() throws IOException {
            stream.flush();
            collector.flush();
        }

        public void write(byte[] b) throws IOException {
            stream.write(b);
            collector.write(b);
        }

        try ( SmbFile r = getDefaultShareRoot();
              SmbFile f = new SmbFile(r, "x-test/") ) {
            if ( !f.exists() ) {
                f.mkdirs();
            }
        }

        // fresh connection
        CIFSContext ctx = getNewContext();
        try ( SmbFile r = new SmbFile(getTestShareURL(), withTestNTLMCredentials(ctx));
              SmbFile f = new SmbFile(r, "x-test/") ) {

            this.stream.close();
            this.collector.close();
        }


        @Override
        public void flush () throws IOException {
            this.stream.flush();
            this.collector.flush();
        }


        @Override
        public void write ( byte[] b ) throws IOException {
            this.stream.write(b);

            break;
        case SMB2_CREATE:
            c = "SMB2_CREATE";
            break;
        case SMB2_CLOSE:
            c = "SMB2_CLOSE";
            break;
        case SMB2_FLUSH:
            c = "SMB2_FLUSH";
            break;
        case SMB2_READ:
            c = "SMB2_READ";
            break;
        case SMB2_WRITE:
            c = "SMB2_WRITE";
            break;

                if (log.level >= 6) {
                    Hexdump.hexdump( log, sbuf, 4, n );
                }
            }

            out.write( sbuf, 0, 4 + n );
            out.flush();
            /* Note the Transport thread isn't running yet so we can
             * read from the socket here.
             */
            if (peekKey() == null) /* try to read header */