*/
    @Override
    public int size() {
        return 40;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.Encodable#encode(byte[], int)
     */
    @Override
    public int encode(final byte[] dst, int dstIndex) {
        final int start = dstIndex;
        SMBUtil.writeTime(this.createTime, dst, dstIndex);
        dstIndex += 8;

		tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
		for {
			select {
			case ev := <-localCh:
				buf.Reset()
				tmpEvt.Records[0] = ev
				if err := enc.Encode(tmpEvt); err != nil {
					bugLogIf(ctx, err, "event: Encode failed")
					continue
				}
				mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...)
			case <-ctx.Done():
				grid.PutByteBuffer(buf.Bytes())
				return
			}
		}

    }

    @Test
    @DisplayName("Test encode and decode operations")
    void testEncodeDecodeOperations() {
        byte[] buffer = new byte[1024];

        // Initialize transaction buffer to avoid NPE
        transaction.setBuffer(new byte[SmbComTransaction.TRANSACTION_BUF_SIZE]);

        // Test encode
        int encodeLength = transaction.encode(buffer, 0);
        assertTrue(encodeLength > 0);

	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)

	for i := range items {
		if err = enc.Encode(items[i]); err != nil {
			return err
		}
	}

	path := filepath.Join(store.directory, key.String())
	if key.Compress {
		err = os.WriteFile(path, s2.Encode(nil, buf.Bytes()), os.FileMode(0o770))
	} else {
		err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770))
	}

	buf.Reset()

            for (final LockingAndXRange lockingAndXRange : this.unlocks) {
                dstIndex += lockingAndXRange.encode(dst, dstIndex);
            }
        }
        if (this.locks != null) {
            for (final LockingAndXRange lockingAndXRange : this.locks) {
                dstIndex += lockingAndXRange.encode(dst, dstIndex);
            }
        }
        return start - dstIndex;
    }

    /**

    @DisplayName("Should handle buffer overflow during encode")
    void testBufferOverflowEncode() {
        // Given
        byte[] shortBuffer = new byte[20]; // Too short for transform header
        // Note: Protocol ID is not set on transform header - it's part of the encrypted message

        // When/Then
        assertThrows(Exception.class, () -> {
            transformHeader.encode(shortBuffer, 0);
        });
    }

        assertEquals(newFlags, leaseContext.getLeaseFlags());
    }

    @Test
    @DisplayName("Should encode context correctly")
    void testEncode() {
        byte[] buffer = new byte[leaseContext.size()];
        int encoded = leaseContext.encode(buffer, 0);

        assertEquals(leaseContext.size(), encoded);

        // Verify context header structure according to MS-SMB2

/// note | Teknik Detaylar

Formlardan gelen veri, dosya içermiyorsa normalde "media type" olarak `application/x-www-form-urlencoded` ile encode edilir.

Ancak form dosya içeriyorsa `multipart/form-data` olarak encode edilir. `File` kullanırsanız, **FastAPI** dosyaları body’nin doğru kısmından alması gerektiğini bilir.

        pairs.add(rep);
    }

    /**
     * Encodes a list of AV pairs into byte array format
     *
     * @param pairs the list of AV pairs to encode
     * @return encoded avpairs
     */
    public static byte[] encode(final List<AvPair> pairs) {
        int size = 0;
        for (final AvPair p : pairs) {
            size += 4 + p.getRaw().length;
        }
        size += 4;

Якщо вам потрібне щось просте для інтеграції з FastAPI, але більш надійне, з підтримкою Redis, PostgreSQL чи інших, перегляньте [encode/broadcaster](https://github.com/encode/broadcaster).

///

## Детальніше { #more-info }

Щоб дізнатися більше про можливості, перегляньте документацію Starlette:

* [Клас `WebSocket`](https://www.starlette.dev/websockets/).