Close

Spring - Java 8 Stream support in ObjectProvider to retrieve beans stream

[Last Updated: Dec 22, 2023]

Spring 5.1 added following new methods in ObjectProvider interface which provides Java 8 Stream support.


default java.util.stream.Stream<T> stream()

This method returns a sequential Stream over all matching bean instances, without specific ordering guarantees (but typically in registration order).


default java.util.stream.Stream<T> orderedStream()

This method returns a sequential Stream over all matching object instances. By default elements of the stream are pre-ordered according to the bean factory's common order comparator. We can specify our own order by using @Order annotation or by implementing Ordered`interface.


Starting Spring 5.1, ObjectProvider also extends java.lang.Iterable<T> interface, that means default methods Iterable#forEach(..) and Iterable#spliterator() can also be used, along with Iterable#iterator() which is implemented by ObjectProvider.

Examples

Example bean

public class MsgBean {
  private String msg;

  public MsgBean(String msg) {
      this.msg = msg;
  }

  public void showMessage() {
      System.out.println("msg: " + msg);
  }
    .............
}

stream() example

@Configuration
public class StreamExample {

  @Bean
  MsgBean msgBean() {
      return new MsgBean("test msg 1");
  }

  @Bean
  MsgBean msgBean2() {
      return new MsgBean("test msg 2");
  }

  public static void main(String[] args) {
      AnnotationConfigApplicationContext context =
              new AnnotationConfigApplicationContext(StreamExample.class);
      ObjectProvider<MsgBean> beanProvider = context.getBeanProvider(MsgBean.class);
      beanProvider.iterator().forEachRemaining(System.out::println);
  }
}

Output

MsgBean{msg='test msg 1'}
MsgBean{msg='test msg 2'}

orderedStream() examples

Using @Ordered annotation

@Configuration
public class OrderedStreamExample {

  @Bean
  @Order(2)
  MsgBean msgBean() {
      return new MsgBean("test msg 1");
  }

  @Bean
  @Order(1)
  MsgBean msgBean2() {
      return new MsgBean("test msg 2");
  }

  public static void main(String[] args) {
      AnnotationConfigApplicationContext context =
              new AnnotationConfigApplicationContext(OrderedStreamExample.class);
      ObjectProvider<MsgBean> beanProvider = context.getBeanProvider(MsgBean.class);
      System.out.println("-- default order --");
      beanProvider.stream().forEach(System.out::println);
      System.out.println("-- ordered by @Order --");
      beanProvider.orderedStream().forEach(System.out::println);
  }
}

Output

-- default order --
MsgBean{msg='test msg 1'}
MsgBean{msg='test msg 2'}
-- ordered by @Order --
MsgBean{msg='test msg 2'}
MsgBean{msg='test msg 1'}

Using Ordered interface

public class MsgBean2 implements Ordered {
  private String msg;
  private int order;

  public MsgBean2(String msg, int order) {
      this.msg = msg;
      this.order = order;
  }

  public void showMessage() {
      System.out.println("msg: " + msg);
  }

  @Override
  public int getOrder() {
      return order;
  }
    .............
}
@Configuration
public class OrderedStreamExample2 {

  @Bean
  MsgBean2 msgBean() {
      return new MsgBean2("test msg 1", 2);
  }

  @Bean
  MsgBean2 msgBean2() {
      return new MsgBean2("test msg 2", 1);
  }

  public static void main(String[] args) {
      AnnotationConfigApplicationContext context =
              new AnnotationConfigApplicationContext(OrderedStreamExample2.class);
      ObjectProvider<MsgBean2> beanProvider = context.getBeanProvider(MsgBean2.class);
      System.out.println("-- default order --");
      beanProvider.stream().forEach(System.out::println);
      System.out.println("-- ordered by Ordered interface --");
      beanProvider.orderedStream().forEach(System.out::println);
  }
}

Output

-- default order --
MsgBean2{msg='test msg 1'}
MsgBean2{msg='test msg 2'}
-- ordered by Ordered interface --
MsgBean2{msg='test msg 2'}
MsgBean2{msg='test msg 1'}

Using Iterable methods

Using Iterable#forEach() method:

@Configuration
public class IteratorExample {

  @Bean
  MsgBean msgBean() {
      return new MsgBean("test msg 1");
  }

  @Bean
  MsgBean msgBean2() {
      return new MsgBean("test msg 2");
  }

  public static void main(String[] args) {
      AnnotationConfigApplicationContext context =
              new AnnotationConfigApplicationContext(IteratorExample.class);
      ObjectProvider<MsgBean> beanProvider = context.getBeanProvider(MsgBean.class);
      beanProvider.forEach(System.out::println);
  }
}

Output

MsgBean{msg='test msg 1'}
MsgBean{msg='test msg 2'}

Using Iterable#iterator() method:

@Configuration
public class IteratorExample2 {

  @Bean
  MsgBean msgBean() {
      return new MsgBean("test msg 1");
  }

  @Bean
  MsgBean msgBean2() {
      return new MsgBean("test msg 2");
  }

  public static void main(String[] args) {
      AnnotationConfigApplicationContext context =
              new AnnotationConfigApplicationContext(IteratorExample2.class);
      ObjectProvider<MsgBean> beanProvider = context.getBeanProvider(MsgBean.class);
      beanProvider.iterator().forEachRemaining(System.out::println);
  }
}

Output

MsgBean{msg='test msg 1'}
MsgBean{msg='test msg 2'}

Example Project

Dependencies and Technologies Used:

  • spring-context 6.1.2 (Spring Context)
     Version Compatibility: 5.1.0.RELEASE - 6.1.2Version List
    ×

    Version compatibilities of spring-context with this example:

    • 5.1.0.RELEASE
    • 5.1.1.RELEASE
    • 5.1.2.RELEASE
    • 5.1.3.RELEASE
    • 5.1.4.RELEASE
    • 5.1.5.RELEASE
    • 5.1.6.RELEASE
    • 5.1.7.RELEASE
    • 5.1.8.RELEASE
    • 5.1.9.RELEASE
    • 5.1.10.RELEASE
    • 5.1.11.RELEASE
    • 5.1.12.RELEASE
    • 5.1.13.RELEASE
    • 5.1.14.RELEASE
    • 5.1.15.RELEASE
    • 5.1.16.RELEASE
    • 5.1.17.RELEASE
    • 5.1.18.RELEASE
    • 5.1.19.RELEASE
    • 5.1.20.RELEASE
    • 5.2.0.RELEASE
    • 5.2.1.RELEASE
    • 5.2.2.RELEASE
    • 5.2.3.RELEASE
    • 5.2.4.RELEASE
    • 5.2.5.RELEASE
    • 5.2.6.RELEASE
    • 5.2.7.RELEASE
    • 5.2.8.RELEASE
    • 5.2.9.RELEASE
    • 5.2.10.RELEASE
    • 5.2.11.RELEASE
    • 5.2.12.RELEASE
    • 5.2.13.RELEASE
    • 5.2.14.RELEASE
    • 5.2.15.RELEASE
    • 5.2.16.RELEASE
    • 5.2.17.RELEASE
    • 5.2.18.RELEASE
    • 5.2.19.RELEASE
    • 5.2.20.RELEASE
    • 5.2.21.RELEASE
    • 5.2.22.RELEASE
    • 5.2.23.RELEASE
    • 5.2.24.RELEASE
    • 5.2.25.RELEASE
    • 5.3.0
    • 5.3.1
    • 5.3.2
    • 5.3.3
    • 5.3.4
    • 5.3.5
    • 5.3.6
    • 5.3.7
    • 5.3.8
    • 5.3.9
    • 5.3.10
    • 5.3.11
    • 5.3.12
    • 5.3.13
    • 5.3.14
    • 5.3.15
    • 5.3.16
    • 5.3.17
    • 5.3.18
    • 5.3.19
    • 5.3.20
    • 5.3.21
    • 5.3.22
    • 5.3.23
    • 5.3.24
    • 5.3.25
    • 5.3.26
    • 5.3.27
    • 5.3.28
    • 5.3.29
    • 5.3.30
    • 5.3.31
    • Compatible Java Version: 17+
    • 6.0.0
    • 6.0.1
    • 6.0.2
    • 6.0.3
    • 6.0.4
    • 6.0.5
    • 6.0.6
    • 6.0.7
    • 6.0.8
    • 6.0.9
    • 6.0.10
    • 6.0.11
    • 6.0.12
    • 6.0.13
    • 6.0.14
    • 6.0.15
    • 6.1.0
    • 6.1.1
    • 6.1.2

    Versions in green have been tested.

  • JDK 17
  • Maven 3.8.1

Bean Stream Retrieval via ObjectProvider Select All Download
  • spring-object-provider-bean-stream-retrieval
    • src
      • main
        • java
          • com
            • logicbig
              • example
                • StreamExample.java

    See Also