return this.handle.ensureOpen();
    }

    /**
     * Gets the pipe handle implementation for this output stream.
     *
     * @return the handle
     */
    protected SmbPipeHandleImpl getHandle() {
        return this.handle;
    }

    @Override
    public void close() {
        // ignore, the shared file descriptor is closed by the pipe handle
    }

        assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION, netServerEnum2.command);
        assertEquals(SmbComTransaction.NET_SERVER_ENUM2, netServerEnum2.subCommand);
        assertEquals("\\PIPE\\LANMAN", netServerEnum2.name);
        assertEquals(8, netServerEnum2.maxParameterCount);
        assertEquals(16384, netServerEnum2.maxDataCount);
        assertEquals(0, netServerEnum2.maxSetupCount);

    """Represents a single Server-Sent Event.

    When `yield`ed from a *path operation function* that uses
    `response_class=EventSourceResponse`, each `ServerSentEvent` is encoded
    into the [SSE wire format](https://html.spec.whatwg.org/multipage/server-sent-events.html#parsing-an-event-stream)
    (`text/event-stream`).

    If you yield a plain object (dict, Pydantic model, etc.) instead, it is

            jcifs.internal.smb1.com.SmbComReadAndX req = cap.getValue();
            assertEquals(1024, req.getMinCount(), "Named pipe minCount should be 1024");
            assertEquals(1024, req.getMaxCount(), "Named pipe maxCount should be 1024");
            assertEquals(1024, req.getRemaining(), "Named pipe remaining should be 1024");
        }
    }

    @Nested
    @DisplayName("Lifecycle and exception mapping")

import java.io.OutputStream;

/**
 * Handle to an open named pipe
 *
 * @author mbechler
 *
 */
public interface SmbPipeHandle extends AutoCloseable {

    /**
     * Gets the pipe resource associated with this handle.
     *
     * @return the pipe
     */
    SmbPipeResource getPipe();

    /**
     * Gets the input stream for reading from this pipe.
     *
     * @return this pipe's input stream

        if (out != null && !out.isOpen()) {
            throw new IOException("DCERPC pipe is no longer open");
        }

        if (in == null) {
            in = (SmbFileInputStream) pipe.getNamedPipeInputStream();
        }
        if (out == null) {
            out = (SmbFileOutputStream) pipe.getNamedPipeOutputStream();
        }
        if (isDirect) {
            out.writeDirect(buf, off, length, 1);

    /**
     * Constructs a TransPeekNamedPipe request to check the status of a named pipe.
     *
     * @param config the SMB configuration
     * @param pipeName the name of the pipe to peek
     * @param fid the file identifier for the pipe
     */
    public TransPeekNamedPipe(final Configuration config, final String pipeName, final int fid) {
        super(config, SMB_COM_TRANSACTION, TRANS_PEEK_NAMED_PIPE);

/**
 * SMB1 Transaction Wait Named Pipe request implementation.
 * Implements the TRANS_WAIT_NAMED_PIPE transaction to wait for a named pipe
 * to become available when the pipe server is busy or temporarily unavailable.
 *
 * @author mbechler
 */
public class TransWaitNamedPipe extends SmbComTransaction {

    /**
     * Constructs a wait request for a named pipe.
     *
     * @param config the configuration to use

        }

        // NetName (wide string pointer)
        encodeWideStringPointer(buf, netName);

        // ShareName (wide string pointer, optional)
        encodeWideStringPointer(buf, shareName);

        // IpAddress (wide string pointer, optional)
        encodeWideStringPointer(buf, ipAddress);

        // ClientComputerName (wide string pointer)

        @CsvSource({ "'ncacn_np:\\\\server[endpoint=\\pipe\\srvsvc]', ncacn_np, server, '\\pipe\\srvsvc'",
                "'ncacn_np:server[\\pipe\\srvsvc]', ncacn_np, server, '\\pipe\\srvsvc'",
                "'ncacn_np:[\\pipe\\srvsvc]', ncacn_np, 127.0.0.1, '\\pipe\\srvsvc'",
                "'ncacn_np:server[endpoint=\\pipe\\srvsvc]', ncacn_np, server, '\\pipe\\srvsvc'" })