class InnerSubscription
      def initialize(subject, observer)
        @subject = subject
        @observer = observer
      end