FilesExpand file tree

 develop

/

ConversationStreamCall.java

Copy path

BlameMore file actions

BlameMore file actions

Latest commit

 

History

History

History

40 lines (38 loc) · 1.56 KB

 develop

/

ConversationStreamCall.java

Top

File metadata and controls

• Code
• Blame

40 lines (38 loc) · 1.56 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

// Copyright (c) Alibaba, Inc. and its affiliates.

import com.alibaba.dashscope.aigc.conversation.Conversation;

import com.alibaba.dashscope.aigc.conversation.ConversationParam;

import com.alibaba.dashscope.aigc.conversation.ConversationResult;

import com.alibaba.dashscope.exception.ApiException;

import com.alibaba.dashscope.exception.InputRequiredException;

import com.alibaba.dashscope.exception.NoApiKeyException;

import io.reactivex.Flowable;

public class ConversationStreamCall {

public static void testStreamCall() throws ApiException, NoApiKeyException, InputRequiredException {

Conversation conversation = new Conversation();

String prompt = "就当前的海洋污染的情况，写一份限塑的倡议书提纲，需要有理有据地号召大家克制地使用塑料制品";

ConversationParam param = ConversationParam

.builder()

.model(Conversation.Models.QWEN_PLUS)

.prompt(prompt)

.topP(0.8)

.enableSearch(true)

.incrementalOutput(true)

.build();

try{

Flowable<ConversationResult> result = conversation.streamCall(param);

result.blockingForEach(msg->{

System.out.print(msg);

});

}catch(ApiException ex){

System.out.println(ex.getMessage());

}

}

public static void main(String[] args) throws InputRequiredException{

try {

testStreamCall();

} catch (ApiException | NoApiKeyException e) {

System.out.println(e.getMessage());

}

System.exit(0);

}

}