 		}
 	}
 	
-	public var delegateQueue: DispatchQueue? {
+	public var delegateQueue: DispatchQueue {
 		get {
 			return synchronized(self) {
 				return unsafeDelegateQueue

	public init(with config: Config) {
		self.unsafeConfig = config
		self.unsafeStatus = .closed(nil)
		inputStreamDelegate = StreamDelegate(cInputStream)
		outputStreamDelegate = StreamDelegate(cOutputStream)
	}

	
	private static let workingThread = ThreadComponent.detachNew()
	
	private(set) public var unsafeDelegateQueue: DispatchQueue
	private(set) public var unsafeStatus: Status
	private(set) public var unsafeConfig: Config
	
