Class RemoteReceiver

    • Constructor Detail

      • RemoteReceiver

        public RemoteReceiver​(ReteContainer reteContainer)
    • Method Detail

      • addTarget

        public void addTarget​(Address<? extends Receiver> target)
      • pullInto

        public void pullInto​(java.util.Collection<Tuple> collector,
                             boolean flush)
        Description copied from interface: Supplier
        Pulls the contents of this object in this particular moment into a target collection.
        flush - if true, flushing of messages is allowed during the pull, otherwise flushing is not allowed
      • pullIntoWithTimeline

        public void pullIntoWithTimeline​(java.util.Map<Tuple,​Timeline<Timestamp>> collector,
                                         boolean flush)
      • remotePull

        public java.util.Collection<Tuple> remotePull​(boolean flush)
      • update

        public void update​(Direction direction,
                           Tuple updateElement,
                           Timestamp timestamp)
        Description copied from interface: Receiver
        Updates the receiver with a newly found or lost partial matching.