equal
deleted
inserted
replaced
1 /* |
1 /* |
2 * Copyright (c) 2012, 2013, Oracle and/or its affiliates. All rights reserved. |
2 * Copyright (c) 2012, 2018, Oracle and/or its affiliates. All rights reserved. |
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
4 * |
4 * |
5 * This code is free software; you can redistribute it and/or modify it |
5 * This code is free software; you can redistribute it and/or modify it |
6 * under the terms of the GNU General Public License version 2 only, as |
6 * under the terms of the GNU General Public License version 2 only, as |
7 * published by the Free Software Foundation. Oracle designates this |
7 * published by the Free Software Foundation. Oracle designates this |
168 downstream.end(); |
168 downstream.end(); |
169 } |
169 } |
170 |
170 |
171 @Override |
171 @Override |
172 public void accept(T t) { |
172 public void accept(T t) { |
173 if (!seen.contains(t)) { |
173 if (seen.add(t)) { |
174 seen.add(t); |
|
175 downstream.accept(t); |
174 downstream.accept(t); |
176 } |
175 } |
177 } |
176 } |
178 }; |
177 }; |
179 } |
178 } |