throw new SmbException("Already closed");
        }

        if (this.output != null) {
            return this.output;
        }

        try (SmbTreeHandleImpl th = ensureTreeConnected()) {
            this.output = new SmbPipeOutputStream(this, th);
        }
        return this.output;
    }

    /**
     *
     * {@inheritDoc}
     *

            assertNotNull(os1, "Default output stream should not be null");
            assertNotNull(os2, "Output stream with append should not be null");
            assertNotNull(os3, "Output stream with sharing should not be null");
            assertNotNull(os4, "Output stream with full params should not be null");
            assertSame(mockOutputStream, os1, "Should return expected output stream");

  }

  void Run(const std::vector<std::pair<TF_Operation*, TF_Tensor*>>& inputs,
           TF_Operation* output, int32_t expected_result) {
    Run(inputs, {{output, 0}}, {expected_result});
  }

  // Run the host graph, which now contains a function and check that
  // outputs are as expected.
  // 'T' stands for 'tensor' since the outputs are tensors, not scalars.
  void RunT(const std::vector<std::pair<TF_Operation*, TF_Tensor*>>& inputs,

     * Uses the default buffer size and no output callback.
     *
     * @param process the system process to wrap
     */
    public JobProcess(final Process process) {
        this(process, InputStreamThread.MAX_BUFFER_SIZE, null);
    }

    /**
     * Constructs a new JobProcess with the specified process, buffer size, and output callback.
     *
     * @param process the system process to wrap

        assertNotNull(request);
        assertEquals(0x0B, request.getCommand());
        verify(mockConfig).getTransactionBufferSize();
    }

    @Test
    @DisplayName("Test constructor with output buffer")
    void testConstructorWithOutputBuffer() {
        // This constructor doesn't use getTransactionBufferSize()

		if err == nil || !wantErr.MatchString(err.Error()) {
			t.Errorf("want error matching %s, got %s", wantErr, err)
		}
		// And it should flush all output (even if it looks
		// like we may be getting an exit code)
		if got := out.String(); text != got {
			t.Errorf("want full output %q, got %q", text, got)
		}
	}
	wantErr = regexp.MustCompile("^no exit code")
	check("abc")
	check("exitcode")
	check("exitcode=")

    validations:
      required: true

  - type: textarea
    id: expected-behavior
    attributes:
      label: "What did you expect to see?"

  }

  /**
   * Computes intermediate hash of 32 bytes of byte array from the given offset. Results are
   * returned in the output array - this is 12% faster than allocating new arrays every time.
   */
  private static void weakHashLength32WithSeeds(
      byte[] bytes, int offset, long seedA, long seedB, long[] output) {
    long part1 = load64(bytes, offset);
    long part2 = load64(bytes, offset + 8);
    long part3 = load64(bytes, offset + 16);

        @Test
        @DisplayName("Should decode output parameters correctly")
        void testDecodeOut() throws NdrException {
            // Given: Close handle message with mocked return value
            samr.SamrCloseHandle message = new samr.SamrCloseHandle(mockPolicyHandle);
            when(mockNdrBuffer.dec_ndr_long()).thenReturn(0);

            // When: Decoding output
            message.decode_out(mockNdrBuffer);

        byte[] outBuf = new byte[output.length];
        Smb2IoctlResponse resp = new Smb2IoctlResponse(config, outBuf);

        resp.decode(packet, 0);
        assertEquals(output.length, resp.getOutputLength());
        assertArrayEquals(output, outBuf, "Output should be copied into provided buffer");
        // No Decodable output when buffer is provided
        assertNull(resp.getOutputData());