本文整理了Java中cyclops.reactive.ReactiveSeq.concatMap方法的一些代码示例，展示了ReactiveSeq.concatMap的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ReactiveSeq.concatMap方法的具体详情如下：
包路径：cyclops.reactive.ReactiveSeq
类名称：ReactiveSeq
方法名：concatMap

ReactiveSeq.concatMap介绍

暂无

代码示例

代码示例来源：origin: aol/micro-server

default List<Class<?>> getDefaultResources() {
  return PluginLoader.INSTANCE.plugins.get()
                    .stream()
                    .concatMap(Plugin::jaxRsResources)
                    .to(ListX::fromIterable);
}

代码示例来源：origin: aol/micro-server

default List<String> getDefaultJaxRsPackages() {
  return PluginLoader.INSTANCE.plugins.get()
                    .stream()
                    .filter(module -> module.servletContextListeners() != null)
                    .concatMap(Plugin::jaxRsPackages)
                    .to(ListX::fromIterable);
}

代码示例来源：origin: aol/micro-server

default List<ServletRequestListener> getRequestListeners(ServerData data) {
  return PluginLoader.INSTANCE.plugins.get()
                    .stream()
                    .filter(module -> module.servletRequestListeners() != null)
                    .concatMap(Plugin::servletRequestListeners)
                    .map(fn -> fn.apply(data))
                     .to(ListX::fromIterable);
}

代码示例来源：origin: aol/micro-server

default String getProviders() {
  String additional = ReactiveSeq.fromStream(PluginLoader.INSTANCE.plugins.get()
                                      .stream())
                  .peek(System.out::println)
                  .filter(module -> module.providers() != null)
                  .concatMap(Plugin::providers)
                  .join(",");
  if (StringUtils.isEmpty(additional))
    return "com.oath.micro.server.rest.providers";
  return "com.oath.micro.server.rest.providers," + additional;
}

代码示例来源：origin: aol/micro-server

default List<ServletContextListener> getListeners(ServerData data) {
  List<ServletContextListener> list = new ArrayList<>();
  if (data.getRootContext() instanceof WebApplicationContext) {
    list.add(new ContextLoaderListener(
                      (WebApplicationContext) data.getRootContext()));
  }
  ListX<Plugin> modules = PluginLoader.INSTANCE.plugins.get();
  ListX<ServletContextListener> listeners = modules.stream()
                            .filter(module -> module.servletContextListeners() != null)
                            .concatMap(Plugin::servletContextListeners)
                            .map(fn -> fn.apply(data))
                            .to(ListX::fromIterable);
  return listeners.plusAll(list);
}

代码示例来源：origin: aol/micro-server

@Test
public void testProviders(){
  System.out.println(ConfigurableModule.builder().build().getProviders());
  //test MyPlugin working
  
  System.out.println(new ModuleImpl().getProviders());
  String additional = ReactiveSeq
      .fromStream(
          Arrays.<Plugin>asList(new TestPlugin())
              .stream()).filter(module -> module.providers()!=null)
              .concatMap(Plugin::providers)
              .join(",");
  
  assertThat(additional, equalTo(""));
}
static class ModuleImpl  implements Module{

代码示例来源：origin: aol/micro-server

@Test
public void testProviders(){
  //test MyPlugin working
  assertThat("com.oath.micro.server.rest.providers,com.my.new.provider,com.my.new.provider2",
      equalTo(ConfigurableModule.builder().build().getProviders()));
  System.out.println(new ModuleImpl().getProviders());
  String additional = ReactiveSeq
      .fromStream(
          Arrays.asList(new MyPlugin())
              .stream()).filter(module -> module.providers()!=null)
              .concatMap(Plugin::providers)
              .join(",");
  
  assertThat(additional, equalTo("com.my.new.provider,com.my.new.provider2"));
}

代码示例来源：origin: aol/cyclops

@Override
public <R> TreeSet<R> flatMap(Function<? super T, ? extends ImmutableSet<? extends R>> fn) {
  return fromStream(stream().concatMap(fn), Comparators.naturalOrderIdentityComparator());
}
public <R> TreeSet<R> flatMap(Function<? super T, ? extends ImmutableSet<? extends R>> fn,Comparator<? super R> comp) {

代码示例来源：origin: aol/cyclops

@Test
public void flatMapMaybe(){
  assertThat(ReactiveSeq.of(1,2,3,null).concatMap(Maybe::ofNullable)
                           .collect(Collectors.toList()),
                           equalTo(Arrays.asList(1,2,3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void flatMap2(){
  assertThat(Spouts.of(1,2,3)
      .concatMap(i->Spouts.of(1,i))
      .toList(),equalTo(Arrays.asList(1,1,1,2,1,3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void flatMapMaybe(){
  assertThat(of(1,2,3).concatMap(Maybe::ofNullable)
          .collect(Collectors.toList()),
      equalTo(Arrays.asList(1,2,3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void concatMapMaybe() {
  assertThat(of(1, 2, 3).concatMap(Maybe::ofNullable)
          .collect(Collectors.toList()),
      Matchers.equalTo(Arrays.asList(1, 2, 3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void flatMap2(){
  assertThat(Spouts.of(1,2,3)
      .concatMap(i->Spouts.of(1,i))
      .toList(),equalTo(Arrays.asList(1,1,1,2,1,3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void flatMapFlux(){
  for(int i=0;i<10000;i++){
    System.out.println("************Iteration " + i);
    Assert.assertThat(flux(1)
            .concatMap(in -> flux(1, 2, 3))
            .toList(),
        Matchers.equalTo(Arrays.asList(1, 2, 3)));
  }
}

代码示例来源：origin: aol/cyclops

@Test
public void flatMapList(){
  for(int i=0;i<1000;i++){
    System.out.println("************Iteration " + i);
    Assert.assertThat(flux(1)
            .concatMap(in -> of(1, 2, 3))
            .toList(),
        Matchers.equalTo(Arrays.asList(1, 2, 3)));
  }
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void flatMapFlux(){
  for(int i=0;i<10000;i++){
    System.out.println("************Iteration " + i);
    Assert.assertThat(flux(1)
            .concatMap(in -> flux(1, 2, 3))
            .toList(),
        Matchers.equalTo(Arrays.asList(1, 2, 3)));
  }
}

代码示例来源：origin: aol/cyclops

@Test
public void flatMapS() throws InterruptedException{
  //of(1,2,3)
  //		.flatMapP(i->Maybe.of(i)).printOut();
  Assert.assertThat(of(1,2,3)
      .concatMap(i-> Maybe.of(i))
      .toList(), Matchers.equalTo(Arrays.asList(1,2,3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void concatMapStream() {
  assertThat(of(1, 2, 3).concatMap(i -> ReactiveSeq.of(i).filter(Objects::nonNull))
          .collect(Collectors.toList()),
      Matchers.equalTo(Arrays.asList(1, 2, 3)));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void batchBySize() {
  iterate("", last -> "next")
      .limit(100)
      .grouped(10)
      .onePer(1, TimeUnit.MICROSECONDS)
      .peek(batch -> System.out.println("batched : " + batch))
      .concatMap(Function.identity())
      .peek(individual -> System.out.println("Flattened : "
          + individual))
      .forEach(a->{});
}

代码示例来源：origin: aol/cyclops

@Test
public void batchBySize() {
  iterate("", last -> "next")
      .limit(100)
      .grouped(10)
      .onePer(1, TimeUnit.MICROSECONDS)
      .peek(batch -> System.out.println("batched : " + batch))
      .concatMap(i->i)
      .peek(individual -> System.out.println("Flattened : "
          + individual))
      .forEach(a->{});
}