We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8e7dd8e commit b86525dCopy full SHA for b86525d
src/DotJEM.Json.Index2.Management/IJsonIndexManager.cs
@@ -45,12 +45,14 @@ public JsonIndexManager(
45
IJsonDocumentSource jsonDocumentSource,
46
IJsonIndexSnapshotManager snapshots,
47
//TODO: Allow multiple indexes and something that can shard
48
- IJsonIndex index)
+ IJsonIndex index,
49
+ IJsonIndexWriter writer = null)
50
{
51
this.jsonDocumentSource = jsonDocumentSource;
52
this.snapshots = snapshots;
53
this.index = index;
- this.writer = new JsonIndexWriter(index);
54
+ this.writer = writer ?? new JsonIndexWriter(index);
55
+ this.writer.InfoStream.Subscribe(infoStream);
56
57
Tracker = new IngestProgressTracker();
58
jsonDocumentSource.DocumentChanges.ForEachAsync(CaptureChange);
0 commit comments