       get() match {         case null =>           if (VirtualProcessor.Debug)             println(s"VirtualPublisher#$hashCode(null).onError(${ex.getMessage}) -> ErrorPublisher")           if (!compareAndSet(