小编pau*_*aul的帖子

Concat VS Merge运算符

我正在检查RXJava的文档,我注意到concat和merge运算符似乎也是这样.我写了几个测试以确定.

@Test
public void testContact() {

    Observable.concat(Observable.just("Hello"),
                      Observable.just("reactive"),
                      Observable.just("world"))
              .subscribe(System.out::println);
}

@Test
public void testMerge() {

    Observable.merge(Observable.just("Hello"),
                      Observable.just("reactive"),
                      Observable.just("world"))
            .subscribe(System.out::println);
}
Run Code Online (Sandbox Code Playgroud)

文件说

Merge运算符也类似.它结合了两个或多个Observable的发射,但可以交错它们,而Concat从不交错来自多个Observable的发射.

但是我还是不完全明白,运行这个测试千次,合并结果总是一样的.由于订单未被授予,我期待有时"反应性""世界""你好".

代码在这里https://github.com/politrons/reactive

java java-8 rx-java

40
推荐指数
2
解决办法
3万
查看次数

计入Spring Data MongoDB存储库

我想知道是否有任何机制可以count在带有@Query注释的Spring Data MongoDB存储库中使用?我很乐意收到我所拥有的文件数量,而无需获得所有这些文件.

基本上,相当于Java中的这个:

db.test.find({"type":"foo"}).count 
Run Code Online (Sandbox Code Playgroud)

java spring mongodb spring-data

16
推荐指数
2
解决办法
2万
查看次数

如何使用查询注释删除MongoRepository中的项目?

我正在使用MongoDB使用Spring数据和MongoDB.

我想知道是否可以使用查询注释通过过滤器进行删除.我一直在这里和谷歌,我找不到任何文件.

java spring mongodb spring-data

16
推荐指数
2
解决办法
2万
查看次数

RxJava1和RxJava2之间的差异

我一直在寻找RxJava1 https://github.com/ReactiveX/RxJava/releases和RxJava2 https://github.com/ReactiveX/RxJava/wiki/Reactive-Streams的文档,看起来与RxJava 的独特之处在于2有Java Stream.

还有其他不同吗?

我一直在使用1.1.3版本,但我不确定是否值得将其转移到RxJava2,因为我们已经在代码中使用了Java 8流

问候.

java java-8 rx-java

15
推荐指数
2
解决办法
8123
查看次数

嵌套数组中的Mongodb Increment值

我正在为Spring使用mongotemplate,我想知道如何以原子方式增加我在一个数组中的一个文件的值.想象一下,我们有

{'a':1,
   b:[{_id:341432,
       c:2
      },
      {_id:341445,
       c:3
      }]};
Run Code Online (Sandbox Code Playgroud)

对于_id 341445,我想要的是将c从3增加到4

我一直在使用findAndModify,但我不知道如何为数组中的嵌套文档创建它.

问候.

java spring mongodb

14
推荐指数
1
解决办法
1万
查看次数

Spring数据mongo在Query中使用OR

我们来看看有人可以帮忙解决这个问题.

我想使用Spring Data mongodb的Repository,我想使用Query annotation来过滤find by value A=10 or A=20

  @Query("{A: 10, A:20}")
  findById(int id);
Run Code Online (Sandbox Code Playgroud)

勉强","尝试制作一个AND,我需要一个OR.

有什么好主意吗?

java spring mongodb spring-data

14
推荐指数
5
解决办法
4万
查看次数

AWS Export配置为cloudformation模板

我正在使用AWS CLI和cloudformation,我在文档中找不到任何参考.

任何人都知道是否可以从当前配置创建一个云形态模板.

假设我想从当前的安全组配置中获取一个cloudformation模板.

是否有可能使用命令行将该配置导出为模板?

问候.

amazon-ec2 amazon-web-services aws-cloudformation

13
推荐指数
3
解决办法
1万
查看次数

将元素添加到Array中

我试图动态地将一个元素添加到数组中:

   array=("element1" "element2" "element3")
   fa=()
   # now loop through the above array
   for i in "${array[@]}"
   do
      fa+=("$i")
      # or do whatever with individual element of the array
   done

   echo $fa
Run Code Online (Sandbox Code Playgroud)

但它正在回归element1.

我试过一个索引,但我得到了相同的结果:

fa[index]="$i"
((index++))
Run Code Online (Sandbox Code Playgroud)

我在这里做错了吗?

bash shell

11
推荐指数
1
解决办法
1万
查看次数

使用Generic类型收集流

我试图在一个方法中使用泛型,我将json反序列化为pojo,因此它可以返回任何对象类型.

这是我的代码:

private Bla(List<A> as, List<B> bs)
{
    this.as = as;
    this.bs = bs;
}

public static Bla from(JsonObject json)
{
    return new Bla(Bla.<A>load(json, As), Bla.<B>load(json, Bs));
}

private static <T> List<T> load(JsonObject jsonObject, String param)
{
    return jsonObject.getJsonArray(param).stream()
                                         .map(Bla::getItem)
                                         .collect(Collectors.toList());
}

private static <T> T getItem(Object json)
{
    try {
        return mapper.readValue(json.toString(), new TypeReference<T>() {
        });
    } catch (IOException e) {
        throw new RuntimeException("Error parsing json items", e);
    }
}
Run Code Online (Sandbox Code Playgroud)

问题是.collect(Collectors.toList());似乎没有编译原因无法解析实例类型.

编译错误是:

Error:(43, 25) java: incompatible types: …

java java-8

11
推荐指数
1
解决办法
5039
查看次数

使用 Maven 执行器跳过模块

enforcer在根 pom 的多节点项目中使用插件,但我有一个测试模块,我真的不关心在那里运行插件,因为它不会创建任何 jar 并且仅用于测试 propuse。有没有办法跳过插件配置中的模块之一?

检查文档我找不到任何东西。只有如何禁止某些特定的依赖项。https://maven.apache.org/enforcer/enforcer-rules/bannedDependencies.html

将插件放在每个子模块中的解决方案是可能的,但它很危险,因为如果我创建一个新的子模块,我可能会忘记在那里添加它

这是我的插件配置。

      <plugin>
          <groupId>org.apache.maven.plugins</groupId>
          <artifactId>maven-enforcer-plugin</artifactId>
          <version>3.0.0-M3</version>
          <executions>
            <execution>
              <id>enforce-maven-version-and-dependencies</id>
              <goals>
                <goal>enforce</goal>
              </goals>
              <configuration>
                <rules>
                  <requireMavenVersion>
                    <version>3.3.9</version>
                  </requireMavenVersion>
                  <bannedDependencies>
                    <searchTransitive>true</searchTransitive>
                  </bannedDependencies>
                  <dependencyConvergence></dependencyConvergence>
                </rules>
              </configuration>
            </execution>
          </executions>
          <configuration>
            <fail>true</fail>
          </configuration>
        </plugin>
Run Code Online (Sandbox Code Playgroud)

java maven-plugin maven maven-enforcer-plugin

9
推荐指数
2
解决办法
4715
查看次数