 				}
 			}
 
-			disposable.addDisposable {
+			let _ = disposable.addDisposable {
 				channel.close(flags: .stop)
 			}
 		}

						disposable += signalDisposable
					}

					disposable.addDisposable {
						rawTask.terminate()
					}
				}

	
	/// wait for all task termination
	public static func waitForAllTaskTermination() {
		let _ = Task.group.wait(timeout: DispatchTime.distantFuture)
	}
}

