add async feature #1

Merged

b4tman merged 62 commits from async into master 2023-08-18 09:29:46 +03:00

Conversation 0 Commits 62 Files Changed 14

+2747 -325

b4tman commented 2023-08-06 01:11:21 +03:00

Owner

Copy Link

Copy Source

for use in async context with tokio

for use in async context with tokio

b4tman added 10 commits 2023-08-06 01:11:22 +03:00

add sync/async features a6e5931f35

fix set_pledged_src_size 307790ce49

add async writer abcb7d6dc2

optional feature for source 0c0a4e31ba

move macro to convert mod 150527efeb

add async reader 1ba645f337

add async reader stream 39ce0d8ceb

add async test_share_reader cad8ff0404

ci: add pipeline type 5632c19866

ci: build/test with --all-features a496f37ef2

b4tman added 1 commit 2023-08-06 01:19:30 +03:00

ci: add "publish" pipeline type c0193e4f74

b4tman added 3 commits 2023-08-06 17:03:34 +03:00

move str_err to util.rs f55b6f681c

+ async source ... ecfc34e821

(reader and converter)

ci: fix pipeline build 851058245d

b4tman added 8 commits 2023-08-08 14:33:40 +03:00

rewrite SourceQuestionsZipReaderAsync stream ... 80dda8d821

(poll_next not work)

rewrite async converter ... 467ebfcc67

(poll_next removed // not work)

add app_async ... 8c4631e89f

-- write invalid:
"UnexpectedEnd { additional: 385 }"

rewrite SourceQuestionsZipReaderAsync ... 7cbf5439b7

"impl Stream for SourceQuestionsZipReaderAsync" dropped

combine convert sync/async features b768d27f83

replace PhantomData in async_db::Writer ... a1a1d41403

for Send for Writer

fix async_db tests (to fail) ... 965c021d83

---
failures:
    async_db::test::test_write_read
    async_db::test::test_write_read_stream

thread 'async_db::test::test_write_read' panicked at 'get: "UnexpectedEnd { additional: 1 }

fix app_async 8306c76a0c

b4tman added 4 commits 2023-08-08 17:10:09 +03:00

fix write_db tokio join 2c3950ccfc

remove debug prints daf41625ff

fix async_db tests ... 4c555df8ca

using ZstdEncoder from ..:tokio::bufread instead of ..:tokio::write

fmt f2fc72056b

b4tman added 1 commit 2023-08-08 17:10:28 +03:00

Revert "ci: fix pipeline build" ... 48438c1aec

This reverts commit 851058245d.

b4tman added 1 commit 2023-08-10 11:22:49 +03:00

PhantomData<Arc<T>> 68b276ce5e

b4tman added 1 commit 2023-08-10 11:51:14 +03:00

Merge branch 'master' into async 9c4882fbbb

b4tman force-pushed async from 65b2126bc7 to f874e59a11 2023-08-10 14:22:50 +03:00 Compare

b4tman added 5 commits 2023-08-12 22:13:38 +03:00

source: add skip_serializing_if attr's 21571787f2

deps: add insta for tests d4913a13f9

add source batch ser/de tests 7e633577b1

add source::reader_sync get/iter tests 08acb4e71b

add source::reader_async get/stream tests ef98b1fea4

b4tman added 1 commit 2023-08-12 22:35:00 +03:00

source: reformat struct's e32316c6aa

b4tman added 2 commits 2023-08-12 22:54:30 +03:00

source tests: check write on write_sample_zip acf741e721

questions: add skip_serializing_if attr's c061fef267

b4tman added 1 commit 2023-08-12 23:35:30 +03:00

add questions ser/de tests e0326e3b0a

b4tman added 4 commits 2023-08-13 13:20:14 +03:00

fix clippy warnings in tests ed37fee697

source tests: reuse fn sample_batch() 8e87e5e17b

questions: add sync convert test ff6af8389d

questions: add async convert_stream test 270af2c373

b4tman marked the pull request as ready for review 2023-08-13 13:23:54 +03:00

b4tman added 4 commits 2023-08-13 18:17:13 +03:00

questions: add QuestionsConverterAsyncForStream cd87529ede

fix source decode 908a6d8cae

async deps: add pin-project 3e3572ce12

async_db: add WriterSink 31c02ae8ef

b4tman added 4 commits 2023-08-14 15:55:12 +03:00

questions converter: remove src clone c326fc59d3

add utils::BincodeVecWriter ddd728cd5d

use BincodeVecWriter in async_db ... e074108560

for reusing current item buf

use BincodeVecWriter in (sync) db ... 645b654dac

for reusing current item buf

b4tman added 1 commit 2023-08-14 16:25:15 +03:00

async_db: add Reader::get_with_buf +test 3ea4930105

b4tman added 1 commit 2023-08-14 17:20:12 +03:00

async_db: refactor WriterSink::poll_ready f1d4cf05c5

b4tman added 5 commits 2023-08-15 16:47:39 +03:00

async_db "fixme" comments 07d7ba50cc

app_async: don't use writer.sink() 0adc11cabf

add test for writer.sink() 9196c61a12

db(+async) writer: add push_by_ref 5ed0398203

add FIXME comment ae96fb3bf8

b4tman added 3 commits 2023-08-16 12:06:35 +03:00

async_db: add BufReader, BufReaderStream ... feb2303db9

for using as mutable reader

app_async: fix Reader::new 33abc15268

async_db: add [bufread, bufread_stream] tests 6d850be1dc

b4tman added 1 commit 2023-08-16 15:10:40 +03:00

app_async: use for_each_concurrent 797f781959

b4tman merged commit a0c13ea205 into master 2023-08-18 09:29:46 +03:00

b4tman deleted branch async 2023-08-18 09:29:46 +03:00

b4tman referenced this issue from a commit 2023-08-18 09:29:47 +03:00

Merge pull request 'add async feature' (#1) from async into master

Sign in to join this conversation.

Reviewers

No Reviewers

Labels

No items

No labels

Milestone

No items

No Milestone

Projects

Clear projects

No projects

Assignees

Clear assignees

b4tman (Dmitry Belyaev)

No Assignees

1 Participants

Notifications

Subscribe

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: b4tman/chgk_ledb#1