@SuppressWarnings("unlikely-arg-type") @Test public void testEquals() { ApplyFunction pt1 = new ApplyFunction(Numbers.addition); ApplyFunction pt2 = new ApplyFunction(Numbers.addition); assertTrue(pt1.equals(pt1)); assertFalse(pt1.equals(pt2)); assertFalse(pt1.equals(Numbers.addition)); assertFalse(pt1.equals(null)); }
@Override public final boolean equals(Object o) { if (o == null || !(o instanceof Processor)) { return false; } Processor p = (Processor) o; return m_uniqueId == p.m_uniqueId; }
Processor implements DuplicableProcessor, 
  Contextualizable, Printable, Readable { @Override public final boolean equals(Object o) { if (o == null || !(o instanceof Processor)) { return false; } Processor p = (Processor) o; return m_uniqueId == p.m_uniqueId; } }
Processor implements DuplicableProcessor, 
  Contextualizable, Printable, Readable { @Override public final boolean equals(Object o) { if (o == null || !(o instanceof Processor)) { return false; } Processor p = (Processor) o; return m_uniqueId == p.m_uniqueId; } @SuppressWarnings("unchecked") //@ requires in_arity >= 0 //@ requires out_arity >= 0  Processor(int in_arity, int out_arity); }
Processor implements DuplicableProcessor, 
  Contextualizable, Printable, Readable { @Override public final boolean equals(Object o) { if (o == null || !(o instanceof Processor)) { return false; } Processor p = (Processor) o; return m_uniqueId == p.m_uniqueId; } @SuppressWarnings("unchecked") //@ requires in_arity >= 0 //@ requires out_arity >= 0  Processor(int in_arity, int out_arity); final synchronized Object getContext(/*@ non_null @*/ String key); @Override synchronized Context getContext(); @Override synchronized void setContext(/*@ non_null @*/ String key, Object value); @Override synchronized void setContext(/* @Null */ Context context); @Override final int hashCode(); @Override final boolean equals(Object o); final int getId(); synchronized void reset(); abstract Pushable getPushableInput(int index); final synchronized Pushable getPushableInput(); abstract Pullable getPullableOutput(int index); final synchronized Pullable getPullableOutput(); synchronized void setPullableInput(int i, /*@ non_null @*/ Pullable p); synchronized Pullable getPullableInput(int i); synchronized void setPushableOutput(int i, /*@ non_null @*/ Pushable p); synchronized Pushable getPushableOutput(int i); final int getInputArity(); final int getOutputArity(); static boolean allNull(Object[] v); void duplicateInto(Processor p); final Set<Class<?>> getInputType(int index); void getInputTypesFor(/*@ non_null @*/ Set<Class<?>> classes, int index); Class<?> getOutputType(int index); static Queue<Object[]> getEmptyQueue(); void start(); void stop(); static void startAll(Processor ... procs); static void stopAll(Processor ... procs); final EventTracker getEventTracker(); Processor setEventTracker(/* @Null */ EventTracker tracker); void associateToInput(int in_stream_index, int in_stream_pos, int out_stream_index,
      int out_stream_pos); void associateTo(NodeFunction f, int out_stream_index, int out_stream_pos); void associateToOutput(int in_stream_index, int in_stream_pos, int out_stream_index,
      int out_stream_pos); final int getInputCount(); final int getOutputCount(); @Override final Object print(ObjectPrinter<?> printer); @SuppressWarnings("unchecked") @Override final Processor read(ObjectReader<?> reader, Object o); @Override /*@ non_null @*/ final Processor duplicate(); @Override /*@ non_null @*/ abstract Processor duplicate(boolean with_state); static List<ProvenanceNode> getLeaves(ProvenanceNode root); }
Processor implements DuplicableProcessor, 
  Contextualizable, Printable, Readable { @Override public final boolean equals(Object o) { if (o == null || !(o instanceof Processor)) { return false; } Processor p = (Processor) o; return m_uniqueId == p.m_uniqueId; } @SuppressWarnings("unchecked") //@ requires in_arity >= 0 //@ requires out_arity >= 0  Processor(int in_arity, int out_arity); final synchronized Object getContext(/*@ non_null @*/ String key); @Override synchronized Context getContext(); @Override synchronized void setContext(/*@ non_null @*/ String key, Object value); @Override synchronized void setContext(/* @Null */ Context context); @Override final int hashCode(); @Override final boolean equals(Object o); final int getId(); synchronized void reset(); abstract Pushable getPushableInput(int index); final synchronized Pushable getPushableInput(); abstract Pullable getPullableOutput(int index); final synchronized Pullable getPullableOutput(); synchronized void setPullableInput(int i, /*@ non_null @*/ Pullable p); synchronized Pullable getPullableInput(int i); synchronized void setPushableOutput(int i, /*@ non_null @*/ Pushable p); synchronized Pushable getPushableOutput(int i); final int getInputArity(); final int getOutputArity(); static boolean allNull(Object[] v); void duplicateInto(Processor p); final Set<Class<?>> getInputType(int index); void getInputTypesFor(/*@ non_null @*/ Set<Class<?>> classes, int index); Class<?> getOutputType(int index); static Queue<Object[]> getEmptyQueue(); void start(); void stop(); static void startAll(Processor ... procs); static void stopAll(Processor ... procs); final EventTracker getEventTracker(); Processor setEventTracker(/* @Null */ EventTracker tracker); void associateToInput(int in_stream_index, int in_stream_pos, int out_stream_index,
      int out_stream_pos); void associateTo(NodeFunction f, int out_stream_index, int out_stream_pos); void associateToOutput(int in_stream_index, int in_stream_pos, int out_stream_index,
      int out_stream_pos); final int getInputCount(); final int getOutputCount(); @Override final Object print(ObjectPrinter<?> printer); @SuppressWarnings("unchecked") @Override final Processor read(ObjectReader<?> reader, Object o); @Override /*@ non_null @*/ final Processor duplicate(); @Override /*@ non_null @*/ abstract Processor duplicate(boolean with_state); static List<ProvenanceNode> getLeaves(ProvenanceNode root); static final transient String s_versionString; static final transient int MAX_PULL_RETRIES; }