Merge branch 'main' into cv/main-into-beta

xmtp · Apr 1, 2024 · f9f2c12 · f9f2c12
2 parents 5c865e6 + 742281c
commit f9f2c12
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 4 deletions.
diff --git a/example/src/LaunchScreen.tsx b/example/src/LaunchScreen.tsx
@@ -156,6 +156,14 @@ export default function LaunchScreen(
           accessibilityLabel="Unit-tests"
         />
       </View>
+      <View key="stream-tests" style={{ margin: 16, marginTop: 16 }}>
+        <Button
+          color="green"
+          title="Create Stream Tests"
+          onPress={() => navigation.navigate('streamTest')}
+          accessibilityLabel="Unit-tests"
+        />
+      </View>
       {signer && (
         <>
           <View key="connected-dev" style={{ margin: 16 }}>

diff --git a/example/src/tests/tests.ts b/example/src/tests/tests.ts
@@ -1532,7 +1532,7 @@ test('can handle complex streaming setup', async () => {
     metadata: {},
   })
   const allConvMessages: DecodedMessage[] = []
-  conv1.streamMessages(async (message) => {
+  await conv1.streamMessages(async (message) => {
     allConvMessages.push(message)
   })
   await conv1.send({ text: 'Hello' })
@@ -1559,7 +1559,7 @@ test('can handle complex streaming setup', async () => {
     metadata: {},
   })
   const allConv3Messages: DecodedMessage[] = []
-  conv3.streamMessages(async (message) => {
+  await conv3.streamMessages(async (message) => {
     allConv3Messages.push(message)
   })
   await conv1.send({ text: 'Hello' })
@@ -1641,7 +1641,7 @@ test('can handle complex streaming setup with messages from self', async () => {
     metadata: {},
   })
   const allConvMessages: DecodedMessage[] = []
-  conv1.streamMessages(async (message) => {
+  await conv1.streamMessages(async (message) => {
     allConvMessages.push(message)
   })
   await conv1.send({ text: 'Hello' })
@@ -1668,7 +1668,7 @@ test('can handle complex streaming setup with messages from self', async () => {
     metadata: {},
   })
   const allConv3Messages: DecodedMessage[] = []
-  conv3.streamMessages(async (message) => {
+  await conv3.streamMessages(async (message) => {
     allConv3Messages.push(message)
   })
   await conv1.send({ text: 'Hello' })