org.apache.commons/commons-lang3/3.11 : org/apache/commons/lang3/Streams$FailableStream.class

Streams$FailableStream

https://commons.apache.org/proper/commons-lang/: Apache Commons Lang, a package of Java utility classes for the classes that are in java.lang's hierarchy, or are considered to be so standard as to justify existence in java.lang. (The Apache Software Foundation)

Apache License, Version 2.0

C. Scott Ananian
Chris Audley
Stephane Bailliez
Michael Becke
Benjamin Bentmann
Ola Berg
Nathan Beyer
Stefan Bodewig
Janek Bogucki
Mike Bowler
Sean Brown
Alexander Day Chaffee
Al Chou
Greg Coladonato
Maarten Coene
Justin Couch
Michael Davey
Norm Deane
Morgan Delagrange
Ringo De Smet
Russel Dittmar
Steve Downey
Matthias Eichel
Christopher Elkins
Chris Feldhacker
Roland Foerther
Pete Gieser
Jason Gritman
Matthew Hawthorne
Michael Heuer
Chas Honton
Chris Hyzer
Paul Jack
Marc Johnson
Shaun Kalley
Tetsuya Kaneuchi
Nissim Karpenstein
Ed Korthof
Holger Krauth
Rafal Krupinski
Rafal Krzewski
David Leppik
Eli Lindsey
Sven Ludwig
Craig R. McClanahan
Rand McNeely
Hendrik Maryns
Dave Meikle
Nikolay Metchev
Kasper Nielsen
Tim O'Brien
Brian S O'Neill
Andrew C. Oliver
Alban Peignier
Moritz Petersen
Dmitri Plotnikov
Neeme Praks
Eric Pugh
Stephen Putman
Travis Reeder
Antony Riley
Valentin Rocher
Scott Sanders
James Sawle
Ralph Schaer
Henning P. Schmiedehausen
Sean Schofield
Robert Scholte
Reuben Sivan
Ville Skytta
David M. Sledge
Michael A. Smith
Jan Sorensen
Glen Stampoultzis
Scott Stanchfield
Jon S. Stevens
Sean C. Sullivan
Ashwin Suresh
Helge Tesgaard
Arun Mammen Thomas
Masato Tezuka
Daniel Trebbien
Jeff Varszegi
Chris Webb
Mario Winterer
Stepan Koltsov
Holger Hoffstatte
Derek C. Ashmore
Sebastien Riou
Allon Mureinik
Adam Hooper
Chris Karcher
Michael Osipov
Thiago Andrade
Jonathan Baker
Mikhail Mazursky
Fabian Lange
Michał Kordas
Felipe Adorno
Adrian Ber
Mark Dacek
Peter Verhas
Jin Xu

Daniel Rall (CollabNet, Inc.)
Stephen Colebourne (SITA ATS Ltd)
Henri Yandell ()
Steven Caswell ()
Robert Burrell Donkin ()
Gary D. Gregory
Fredrik Westermarck ()
James Carman (Carman Consulting, Inc.)
Niall Pemberton
Matt Benson
Joerg Schaible
Oliver Heger
Paul Benedict
Benedikt Ritter
Duncan Jones
Loic Guibert
Rob Tompkins

public class org.apache.commons.lang3.Streams$FailableStream<O>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.commons.lang3.Streams$FailableStream
  super_class: java.lang.Object
{
  private java.util.stream.Stream<O> stream;
    descriptor: Ljava/util/stream/Stream;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/stream/Stream<TO;>;

  private boolean terminated;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  public void <init>(java.util.stream.Stream<O>);
    descriptor: (Ljava/util/stream/Stream;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // java.util.stream.Stream stream
         0: .line 86
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 87
            aload 0 /* this */
            aload 1 /* stream */
            putfield org.apache.commons.lang3.Streams$FailableStream.stream:Ljava/util/stream/Stream;
         2: .line 88
            return
        end local 1 // java.util.stream.Stream stream
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    3     1  stream  Ljava/util/stream/Stream<TO;>;
    Signature: (Ljava/util/stream/Stream<TO;>;)V
    MethodParameters:
        Name  Flags
      stream  final

  protected void assertNotTerminated();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
         0: .line 91
            aload 0 /* this */
            getfield org.apache.commons.lang3.Streams$FailableStream.terminated:Z
            ifeq 2
         1: .line 92
            new java.lang.IllegalStateException
            dup
            ldc "This stream is already terminated."
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 94
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;

  protected void makeTerminated();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
         0: .line 97
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.assertNotTerminated:()V
         1: .line 98
            aload 0 /* this */
            iconst_1
            putfield org.apache.commons.lang3.Streams$FailableStream.terminated:Z
         2: .line 99
            return
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;

  public org.apache.commons.lang3.Streams$FailableStream<O> filter(org.apache.commons.lang3.Functions$FailablePredicate<O, ?>);
    descriptor: (Lorg/apache/commons/lang3/Functions$FailablePredicate;)Lorg/apache/commons/lang3/Streams$FailableStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
         0: .line 112
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.assertNotTerminated:()V
         1: .line 113
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.commons.lang3.Streams$FailableStream.stream:Ljava/util/stream/Stream;
            aload 1 /* predicate */
            invokestatic org.apache.commons.lang3.Functions.asPredicate:(Lorg/apache/commons/lang3/Functions$FailablePredicate;)Ljava/util/function/Predicate;
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
            putfield org.apache.commons.lang3.Streams$FailableStream.stream:Ljava/util/stream/Stream;
         2: .line 114
            aload 0 /* this */
            areturn
        end local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    3     1  predicate  Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;
    Signature: (Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;)Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
    MethodParameters:
           Name  Flags
      predicate  final

  public void forEach(org.apache.commons.lang3.Functions$FailableConsumer<O, ?>);
    descriptor: (Lorg/apache/commons/lang3/Functions$FailableConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // org.apache.commons.lang3.Functions$FailableConsumer action
         0: .line 133
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.makeTerminated:()V
         1: .line 134
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* action */
            invokestatic org.apache.commons.lang3.Functions.asConsumer:(Lorg/apache/commons/lang3/Functions$FailableConsumer;)Ljava/util/function/Consumer;
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
         2: .line 135
            return
        end local 1 // org.apache.commons.lang3.Functions$FailableConsumer action
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    3     1  action  Lorg/apache/commons/lang3/Functions$FailableConsumer<TO;*>;
    Signature: (Lorg/apache/commons/lang3/Functions$FailableConsumer<TO;*>;)V
    MethodParameters:
        Name  Flags
      action  final

  public <A, R> R collect(java.util.stream.Collector<? super O, A, R>);
    descriptor: (Ljava/util/stream/Collector;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // java.util.stream.Collector collector
         0: .line 186
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.makeTerminated:()V
         1: .line 187
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* collector */
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            areturn
        end local 1 // java.util.stream.Collector collector
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1  collector  Ljava/util/stream/Collector<-TO;TA;TR;>;
    Signature: <A:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/util/stream/Collector<-TO;TA;TR;>;)TR;
    MethodParameters:
           Name  Flags
      collector  final

  public <A, R> R collect(java.util.function.Supplier<R>, java.util.function.BiConsumer<R, ? super O>, java.util.function.BiConsumer<R, R>);
    descriptor: (Ljava/util/function/Supplier;Ljava/util/function/BiConsumer;Ljava/util/function/BiConsumer;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // java.util.function.Supplier pupplier
        start local 2 // java.util.function.BiConsumer accumulator
        start local 3 // java.util.function.BiConsumer combiner
         0: .line 236
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.makeTerminated:()V
         1: .line 237
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* pupplier */
            aload 2 /* accumulator */
            aload 3 /* combiner */
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/function/Supplier;Ljava/util/function/BiConsumer;Ljava/util/function/BiConsumer;)Ljava/lang/Object;
            areturn
        end local 3 // java.util.function.BiConsumer combiner
        end local 2 // java.util.function.BiConsumer accumulator
        end local 1 // java.util.function.Supplier pupplier
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1     pupplier  Ljava/util/function/Supplier<TR;>;
            0    2     2  accumulator  Ljava/util/function/BiConsumer<TR;-TO;>;
            0    2     3     combiner  Ljava/util/function/BiConsumer<TR;TR;>;
    Signature: <A:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/util/function/Supplier<TR;>;Ljava/util/function/BiConsumer<TR;-TO;>;Ljava/util/function/BiConsumer<TR;TR;>;)TR;
    MethodParameters:
             Name  Flags
      pupplier     final
      accumulator  final
      combiner     final

  public O reduce(O, java.util.function.BinaryOperator<O>);
    descriptor: (Ljava/lang/Object;Ljava/util/function/BinaryOperator;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // java.lang.Object identity
        start local 2 // java.util.function.BinaryOperator accumulator
         0: .line 284
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.makeTerminated:()V
         1: .line 285
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* identity */
            aload 2 /* accumulator */
            invokeinterface java.util.stream.Stream.reduce:(Ljava/lang/Object;Ljava/util/function/BinaryOperator;)Ljava/lang/Object;
            areturn
        end local 2 // java.util.function.BinaryOperator accumulator
        end local 1 // java.lang.Object identity
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1     identity  TO;
            0    2     2  accumulator  Ljava/util/function/BinaryOperator<TO;>;
    Signature: (TO;Ljava/util/function/BinaryOperator<TO;>;)TO;
    MethodParameters:
             Name  Flags
      identity     final
      accumulator  final

  public <R> org.apache.commons.lang3.Streams$FailableStream<R> map(org.apache.commons.lang3.Functions$FailableFunction<O, R, ?>);
    descriptor: (Lorg/apache/commons/lang3/Functions$FailableFunction;)Lorg/apache/commons/lang3/Streams$FailableStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // org.apache.commons.lang3.Functions$FailableFunction mapper
         0: .line 299
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.assertNotTerminated:()V
         1: .line 300
            new org.apache.commons.lang3.Streams$FailableStream
            dup
            aload 0 /* this */
            getfield org.apache.commons.lang3.Streams$FailableStream.stream:Ljava/util/stream/Stream;
            aload 1 /* mapper */
            invokestatic org.apache.commons.lang3.Functions.asFunction:(Lorg/apache/commons/lang3/Functions$FailableFunction;)Ljava/util/function/Function;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
            invokespecial org.apache.commons.lang3.Streams$FailableStream.<init>:(Ljava/util/stream/Stream;)V
            areturn
        end local 1 // org.apache.commons.lang3.Functions$FailableFunction mapper
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1  mapper  Lorg/apache/commons/lang3/Functions$FailableFunction<TO;TR;*>;
    Signature: <R:Ljava/lang/Object;>(Lorg/apache/commons/lang3/Functions$FailableFunction<TO;TR;*>;)Lorg/apache/commons/lang3/Streams$FailableStream<TR;>;
    MethodParameters:
        Name  Flags
      mapper  final

  public java.util.stream.Stream<O> stream();
    descriptor: ()Ljava/util/stream/Stream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
         0: .line 308
            aload 0 /* this */
            getfield org.apache.commons.lang3.Streams$FailableStream.stream:Ljava/util/stream/Stream;
            areturn
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
    Signature: ()Ljava/util/stream/Stream<TO;>;

  public boolean allMatch(org.apache.commons.lang3.Functions$FailablePredicate<O, ?>);
    descriptor: (Lorg/apache/commons/lang3/Functions$FailablePredicate;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
         0: .line 331
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.assertNotTerminated:()V
         1: .line 332
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* predicate */
            invokestatic org.apache.commons.lang3.Functions.asPredicate:(Lorg/apache/commons/lang3/Functions$FailablePredicate;)Ljava/util/function/Predicate;
            invokeinterface java.util.stream.Stream.allMatch:(Ljava/util/function/Predicate;)Z
            ireturn
        end local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1  predicate  Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;
    Signature: (Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;)Z
    MethodParameters:
           Name  Flags
      predicate  final

  public boolean anyMatch(org.apache.commons.lang3.Functions$FailablePredicate<O, ?>);
    descriptor: (Lorg/apache/commons/lang3/Functions$FailablePredicate;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.Streams$FailableStream this
        start local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
         0: .line 353
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.assertNotTerminated:()V
         1: .line 354
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.Streams$FailableStream.stream:()Ljava/util/stream/Stream;
            aload 1 /* predicate */
            invokestatic org.apache.commons.lang3.Functions.asPredicate:(Lorg/apache/commons/lang3/Functions$FailablePredicate;)Ljava/util/function/Predicate;
            invokeinterface java.util.stream.Stream.anyMatch:(Ljava/util/function/Predicate;)Z
            ireturn
        end local 1 // org.apache.commons.lang3.Functions$FailablePredicate predicate
        end local 0 // org.apache.commons.lang3.Streams$FailableStream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lorg/apache/commons/lang3/Streams$FailableStream<TO;>;
            0    2     1  predicate  Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;
    Signature: (Lorg/apache/commons/lang3/Functions$FailablePredicate<TO;*>;)Z
    MethodParameters:
           Name  Flags
      predicate  final
}
Signature: <O:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "Streams.java"
NestHost: org.apache.commons.lang3.Streams
InnerClasses:
  public abstract FailableConsumer = org.apache.commons.lang3.Functions$FailableConsumer of org.apache.commons.lang3.Functions
  public abstract FailableFunction = org.apache.commons.lang3.Functions$FailableFunction of org.apache.commons.lang3.Functions
  public abstract FailablePredicate = org.apache.commons.lang3.Functions$FailablePredicate of org.apache.commons.lang3.Functions
  public FailableStream = org.apache.commons.lang3.Streams$FailableStream of org.apache.commons.lang3.Streams
    RuntimeVisibleAnnotations: 
      java.lang.Deprecated()

/

org.apache.commons/ commons-lang3/ 3.11/ org/apache/commons/lang3/Streams$FailableStream.class