* @return a future that completes when unregistration is done
     */
    public CompletableFuture<Void> unregister(WitnessRegistration registration) {
        return CompletableFuture.runAsync(() -> {
            try {
                registration.setState(WitnessRegistrationState.UNREGISTERING);

                WitnessUnregisterRequest request = new WitnessUnregisterRequest();

                throw new RuntimeException(e);
            }
        });
    }
    
    public CompletableFuture<Void> unregister(WitnessRegistration registration) {
        return CompletableFuture.runAsync(() -> {
            try {
                registration.setState(WitnessRegistrationState.UNREGISTERING);
                
                WitnessUnregisterRequest request = new WitnessUnregisterRequest();

     *
     * @param handle notification handle
     */
    private void startAsyncNotification(ChangeNotificationHandle handle) {
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            while (handle.isActive()) {
                try {
                    // Note: Actual SMB2 Change Notify implementation would go here

        if (timeoutSeconds <= 0) {
            timeoutSeconds = DEFAULT_LEASE_BREAK_TIMEOUT;
        }

        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            handleLeaseBreak(key, newState);
        });

        try {
            future.get(timeoutSeconds, TimeUnit.SECONDS);
        } catch (TimeoutException e) {

            // Cancel any pending notifications
            cancelNotification(handle);
        }
    }
    
    private void startAsyncNotification(ChangeNotificationHandle handle) {
        CompletableFuture.runAsync(() -> {
            while (handle.active) {
                try {
                    // Send SMB2 Change Notify request
                    Smb2ChangeNotifyRequest request = new Smb2ChangeNotifyRequest();

## 10. Error Handling

### 10.1 Lease Break Timeout
```java
public void handleLeaseBreakWithTimeout(Smb2LeaseKey key, int newState) {
    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        handleLeaseBreak(key, newState);
    });
    
    try {
        future.get(5, TimeUnit.SECONDS);  // 5 second timeout
    } catch (TimeoutException e) {

        List<CompletableFuture<Void>> futures = new ArrayList<>();
        
        for (HandleInfo handle : handles) {
            futures.add(CompletableFuture.runAsync(() -> {
                try {
                    reconnectHandle(handle);
                } catch (Exception e) {
                    log.error("Failed to reconnect handle: " + handle.path, e);
                }

        final int chunkLength = (i == channelCount - 1) ? 
            length - chunkOffset : chunkSize;
        final ChannelInfo channel = channels.get(i);
        
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            try {
                Smb2ReadRequest request = new Smb2ReadRequest();
                request.setFileId(this.fileId);
                request.setOffset(offset + chunkOffset);

    /**
     * Schedule an address change
     *
     * @param newAddress the new server address
     */
    private void scheduleAddressChange(InetAddress newAddress) {
        CompletableFuture.runAsync(() -> {
            try {
                // This would require transport architecture changes to support address switching
                // For now, log the event