Removed wee-alloc to fix memory leak (#334)

I think this closes #305.

rustwasm/wee_alloc#106 is the most likely issue.

.cargo/config

@@ -1,5 +1,9 @@
 [build]
 target = "wasm32-unknown-unknown"
 
+[target.'cfg(target_arch = "wasm32")']
+runner = 'wasm-bindgen-test-runner'
+
+
 [profile.release]
 lto = true

Cargo.toml

@@ -34,12 +34,6 @@ base64 = "0.13.0"
 # code size when deploying.
 console_error_panic_hook = { version = "0.1.7" }
 
-# `wee_alloc` is a tiny allocator for wasm that is only ~1K in code size
-# compared to the default allocator's ~10K. It is slower than the default
-# allocator, however.
-#
-# Unfortunately, `wee_alloc` requires nightly Rust when targeting wasm for now.
-wee_alloc = { version = "0.4.5" }
 thiserror = "1.0.31"
 
 [dev-dependencies]

Makefile

@@ -11,6 +11,8 @@ build-dev:
 
 test: install-wasm-pack
 	WASM_BINDGEN_TEST_TIMEOUT=30 wasm-pack test --firefox --headless
+	# Using cargo test with wasm-bindgen-test-runner allows to run specific tests
+	#NO_HEADLESS=1 GECKODRIVER=$(which geckodriver) cargo test js_tests::simple
 
 build-fluvio-websocket-proxy:
 	RUST_LOG=debug cargo build --manifest-path ./fluvio-websocket-proxy/Cargo.toml --target $(PROXY_TARGET)

src/lib.rs

@@ -20,11 +20,6 @@ pub use offset::Offset;
 pub use producer::TopicProducer;
 pub use record::Record;
 
-// When the `wee_alloc` feature is enabled, use `wee_alloc` as the global
-// allocator.
-#[global_allocator]
-static ALLOC: wee_alloc::WeeAlloc = wee_alloc::WeeAlloc::INIT;
-
 use js_sys::Reflect;
 use wasm_bindgen::convert::FromWasmAbi;
 use wasm_bindgen::JsValue;

tests/js/simple/simple.js

@@ -2,6 +2,7 @@ import { Offset, Fluvio } from "../../../../../wasm-bindgen-test";
 import { createUUID } from "../utils.js";
 
 const topic = createUUID();
+const NUMB_RECORDS = 100;
 
 var fluvio;
 export const setup = async () => {
@@ -41,13 +42,13 @@ export const test = async () => {
 
   let count = 0;
   const userAgent = navigator.userAgent;
-  while (count < 100) {
+  while (count < NUMB_RECORDS) {
     count++;
     let in_record = `${count}-${userAgent}`;
     await producer.send("", in_record);
   }
   count = 0;
-  while (count < 100) {
+  while (count < NUMB_RECORDS) {
     count++;
     let in_record = `${count}-${userAgent}`;
     let next = await stream.next();

tests/js_tests.rs

@@ -33,12 +33,14 @@ async fn simple() {
         .map_err(FluvioError::try_from)
         .expect("Setup failed");
     web_sys::console::time_end_with_label("simple-setup");
+    web_sys::console::profile_0();
     web_sys::console::time_with_label("simple-test");
     test()
         .await
         .map_err(FluvioError::try_from)
         .expect("Test failed");
     web_sys::console::time_end_with_label("simple-test");
+    web_sys::console::profile_end_0();
     web_sys::console::time_with_label("simple-teardown");
     teardown()
         .await