src/java.base/share/classes/java/util/stream/AbstractPipeline.java

*** 1,7 ****
  /*
!  * Copyright (c) 2012, 2015, Oracle and/or its affiliates. All rights reserved.
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   *
   * This code is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License version 2 only, as
   * published by the Free Software Foundation.  Oracle designates this
--- 1,7 ----
  /*
!  * Copyright (c) 2012, 2016, Oracle and/or its affiliates. All rights reserved.
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   *
   * This code is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License version 2 only, as
   * published by the Free Software Foundation.  Oracle designates this
*** 325,334 ****
--- 325,336 ----
      }
  
      @Override
      @SuppressWarnings("unchecked")
      public S onClose(Runnable closeHandler) {
+         if (linkedOrConsumed)
+             throw new IllegalStateException(MSG_STREAM_LINKED);
          Objects.requireNonNull(closeHandler);
          Runnable existingHandler = sourceStage.sourceCloseAction;
          sourceStage.sourceCloseAction =
                  (existingHandler == null)
                  ? closeHandler